Type Alias futures_util::stream::FlattenUnordered
source · pub type FlattenUnordered<St> = FlattenUnorderedWithFlowController<St, ()>;
Expand description
Stream for the flatten_unordered
method.
Aliased Type§
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<()>