Struct catalyzer::internals::crates::tower::util::CallAllUnordered

pub struct CallAllUnordered<Svc, S>
where
    Svc: Service<<S as Stream>::Item>,
    S: Stream,
{ /* private fields */ }

A stream of responses received from the inner service in received order.

Similar to CallAll except, instead of yielding responses in request order, responses are returned as they are available.

Implementations

impl<Svc, S> CallAllUnordered<Svc, S>

where Svc: Service<<S as Stream>::Item>, <Svc as Service<<S as Stream>::Item>>::Error: Into<Box<dyn Error + Send + Sync>>, S: Stream,

pub fn new(service: Svc, stream: S) -> CallAllUnordered<Svc, S>

Create new CallAllUnordered combinator.

pub fn into_inner(self) -> Svc

Extract the wrapped Service.

Panics

Panics if take_service was already called.

pub fn take_service(self: Pin<&mut CallAllUnordered<Svc, S>>) -> Svc

Extract the wrapped Service.

This CallAllUnordered can no longer be used after this function has been called.

Panics

Panics if take_service was already called.

Trait Implementations

impl<Svc, S> Debug for CallAllUnordered<Svc, S>

where Svc: Debug + Service<<S as Stream>::Item>, S: Debug + Stream, <Svc as Service<<S as Stream>::Item>>::Future: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<Svc, S> Stream for CallAllUnordered<Svc, S>

where Svc: Service<<S as Stream>::Item>, <Svc as Service<<S as Stream>::Item>>::Error: Into<Box<dyn Error + Send + Sync>>, S: Stream,

type Item = Result<<Svc as Service<<S as Stream>::Item>>::Response, Box<dyn Error + Send + Sync>>

Values yielded by the stream.

fn poll_next( self: Pin<&mut CallAllUnordered<Svc, S>>, cx: &mut Context<'_> ) -> Poll<Option<<CallAllUnordered<Svc, S> as Stream>::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, Svc, S> Unpin for CallAllUnordered<Svc, S>

where __Origin<'__pin, Svc, S>: Unpin, Svc: Service<<S as Stream>::Item>, S: Stream,