Trait futures_util::stream::stream::flatten_unordered::FlowController

pub trait FlowController<I, O> {
    // Required method
    fn next_step(item: I) -> FlowStep<I, O>;
}

Returns the next flow step based on the received item.

Required Methods

fn next_step(item: I) -> FlowStep<I, O>

Handles an item producing FlowStep describing the next flow step.

Implementations on Foreign Types

impl<I, O> FlowController<I, O> for ()

fn next_step(item: I) -> FlowStep<I, O>

Implementors

impl<St> FlowController<<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item, <<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item as Stream>::Item> for PropagateBaseStreamError<St>where St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,