FlattenUnordered

futures_util::stream

Type Alias FlattenUnordered 

Source 
pub type FlattenUnordered<St> = FlattenUnorderedWithFlowController<St, ()>;
Expand description

Stream for the flatten_unordered method.

Aliased Type§

pub struct FlattenUnordered<St> {
    inner_streams: FuturesUnordered<PollStreamFut<<St as Stream>::Item>>,
    stream: St,
    poll_state: SharedPollState,
    limit: Option<NonZero<usize>>,
    is_stream_done: bool,
    inner_streams_waker: Arc<WrappedWaker>,
    stream_waker: Arc<WrappedWaker>,
    flow_controller: PhantomData<()>,
}

Fields§

§inner_streams: FuturesUnordered<PollStreamFut<<St as Stream>::Item>>§stream: St§poll_state: SharedPollState§limit: Option<NonZero<usize>>§is_stream_done: bool§inner_streams_waker: Arc<WrappedWaker>§stream_waker: Arc<WrappedWaker>§flow_controller: PhantomData<()>