Module futures_util::stream::stream

Streams

This module contains a number of functions for working with Streams, including the StreamExt trait which adds methods to Stream types.

Re-exports

• pub use self::chain::Chain;
• pub use self::collect::Collect;
• pub use self::unzip::Unzip;
• pub use self::concat::Concat;
• pub use self::count::Count;
• pub use self::cycle::Cycle;
• pub use self::enumerate::Enumerate;
• pub use self::filter::Filter;
• pub use self::filter_map::FilterMap;
• pub use self::fold::Fold;
• pub use self::any::Any;
• pub use self::all::All;
• pub use self::for_each::ForEach;
• pub use self::fuse::Fuse;
• pub use self::into_future::StreamFuture;
• pub use self::map::Map;
• pub use self::next::Next;
• pub use self::select_next_some::SelectNextSome;
• pub use self::peek::NextIf;
• pub use self::peek::NextIfEq;
• pub use self::peek::Peek;
• pub use self::peek::PeekMut;
• pub use self::peek::Peekable;
• pub use self::skip::Skip;
• pub use self::skip_while::SkipWhile;
• pub use self::take::Take;
• pub use self::take_while::TakeWhile;
• pub use self::take_until::TakeUntil;
• pub use self::then::Then;
• pub use self::zip::Zip;
• pub use self::chunks::Chunks;
• pub use self::ready_chunks::ReadyChunks;
• pub use self::scan::Scan;
• pub use self::buffer_unordered::BufferUnordered;
• pub use self::buffered::Buffered;
• pub use self::flatten_unordered::FlattenUnordered;
• pub use self::for_each_concurrent::ForEachConcurrent;
• pub use self::split::ReuniteError;
• pub use self::split::SplitSink;
• pub use self::split::SplitStream;
• pub use self::catch_unwind::CatchUnwind;

Modules

• all 🔒
• any 🔒
• buffer_unordered 🔒
• buffered 🔒
• catch_unwind 🔒
• chain 🔒
• chunks 🔒
• collect 🔒
• concat 🔒
• count 🔒
• cycle 🔒
• enumerate 🔒
• filter 🔒
• filter_map 🔒
• flatten 🔒
• flatten_unordered 🔒
• fold 🔒
• for_each 🔒
• for_each_concurrent 🔒
• forward 🔒
• fuse 🔒
• into_future 🔒
• map 🔒
• next 🔒
• peek 🔒
• ready_chunks 🔒
• scan 🔒
• select_next_some 🔒
• skip 🔒
• skip_while 🔒
• split 🔒
• take 🔒
• take_until 🔒
• take_while 🔒
• then 🔒
• unzip 🔒
• zip 🔒

Structs

• FlatMap
  Stream for the flat_map method.
• FlatMapUnordered
  Stream for the flat_map_unordered method.
• Flatten
  Stream for the flatten method.
• Forward
  Future for the forward method.
• Inspect
  Stream for the inspect method.

Traits

• StreamExt
  An extension trait for Streams that provides a variety of convenient combinator functions.