Module futures_util::stream::stream::flatten_unordered

Structs

• FlattenUnorderedWithFlowController
  Stream for the flatten_unordered method with ability to specify flow controller.
• PollStateBomb 🔒
  Used to execute some function on the given state when dropped.
• PollStreamFut 🔒
  Future which polls optional inner stream.
• SharedPollState 🔒
  Internal polling state of the stream.
• WrappedWaker 🔒
  Will update state with the provided value on wake_by_ref call and then, if there is a need, call inner_waker.

Enums

• FlowStep
  Describes the next flow step.

Constants

• NEED_TO_POLL_ALL 🔒
  Both base stream and inner streams need to be polled.
• NEED_TO_POLL_INNER_STREAMS 🔒
  Inner streams need to be polled.
• NEED_TO_POLL_STREAM 🔒
  The base stream needs to be polled.
• NONE 🔒
  There is nothing to poll and stream isn’t being polled/waking/woken at the moment.
• POLLING 🔒
  The current stream is being polled at the moment.
• WAKING 🔒
  Stream is being woken at the moment.
• WOKEN 🔒
  The stream was waked and will be polled.

Traits

• FlowController
  Returns the next flow step based on the received item.

Type Aliases

• FlattenUnordered
  Stream for the flatten_unordered method.