Module futures_util::stream::try_stream

Streams

This module contains a number of functions for working with Streamss that return Results, allowing for short-circuiting computations.

Re-exports

• pub use self::and_then::AndThen;
• pub use self::into_stream::IntoStream;
• pub use self::or_else::OrElse;
• pub use self::try_next::TryNext;
• pub use self::try_for_each::TryForEach;
• pub use self::try_filter::TryFilter;
• pub use self::try_filter_map::TryFilterMap;
• pub use self::try_flatten::TryFlatten;
• pub use self::try_flatten_unordered::TryFlattenUnordered;
• pub use self::try_collect::TryCollect;
• pub use self::try_concat::TryConcat;
• pub use self::try_chunks::TryChunks;
• pub use self::try_chunks::TryChunksError;
• pub use self::try_ready_chunks::TryReadyChunks;
• pub use self::try_ready_chunks::TryReadyChunksError;
• pub use self::try_fold::TryFold;
• pub use self::try_unfold::try_unfold;
• pub use self::try_unfold::TryUnfold;
• pub use self::try_skip_while::TrySkipWhile;
• pub use self::try_take_while::TryTakeWhile;
• pub use self::try_buffer_unordered::TryBufferUnordered;
• pub use self::try_buffered::TryBuffered;
• pub use self::try_for_each_concurrent::TryForEachConcurrent;
• pub use self::into_async_read::IntoAsyncRead;
• pub use self::try_all::TryAll;
• pub use self::try_any::TryAny;

Modules

• and_then 🔒
• into_async_read 🔒
• into_stream 🔒
• or_else 🔒
• try_all 🔒
• try_any 🔒
• try_buffer_unordered 🔒
• try_buffered 🔒
• try_chunks 🔒
• try_collect 🔒
• try_concat 🔒
• try_filter 🔒
• try_filter_map 🔒
• try_flatten 🔒
• try_flatten_unordered 🔒
• try_fold 🔒
• try_for_each 🔒
• try_for_each_concurrent 🔒
• try_next 🔒
• try_ready_chunks 🔒
• try_skip_while 🔒
• try_take_while 🔒
• try_unfold 🔒

Structs

• ErrInto
  Stream for the err_into method.
• InspectErr
  Stream for the inspect_err method.
• InspectOk
  Stream for the inspect_ok method.
• MapErr
  Stream for the map_err method.
• MapOk
  Stream for the map_ok method.

Traits

• TryStreamExt
  Adapters specific to Result-returning streams