Module tokio_stream::stream_ext

Re-exports

• pub use chain::Chain;
• pub use filter::Filter;
• pub use filter_map::FilterMap;
• pub use fuse::Fuse;
• pub use map::Map;
• pub use map_while::MapWhile;
• pub use merge::Merge;
• pub use skip::Skip;
• pub use skip_while::SkipWhile;
• pub use take::Take;
• pub use take_while::TakeWhile;
• pub use then::Then;
• pub use peekable::Peekable;
• pub use timeout::Timeout;
• pub use timeout_repeating::TimeoutRepeating;
• pub use chunks_timeout::ChunksTimeout;

Modules

• all 🔒
• any 🔒
• chain 🔒
• chunks_timeout 🔒
• collect 🔒
• filter 🔒
• filter_map 🔒
• fold 🔒
• fuse 🔒
• map 🔒
• map_while 🔒
• merge 🔒
• next 🔒
• peekable 🔒
• skip 🔒
• skip_while 🔒
• take 🔒
• take_while 🔒
• then 🔒
• throttle 🔒
  Slow down a stream by enforcing a delay between items.
• timeout 🔒
• timeout_repeating 🔒
• try_next 🔒

Traits

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

Functions

• merge_size_hints 🔒
  Merge the size hints from two streams.