Module futures_util::stream [−][src]
Asynchronous streams.
This module contains:
- The
Stream
trait, for objects that can asynchronously produce a sequence of values. - The
StreamExt
andTryStreamExt
trait, which provides adapters for chaining and composing streams. - Top-level stream constructors like
iter
which creates a stream from an iterator.
Modules
futures_unordered | An unbounded set of futures. |
Structs
AndThen | Stream for the |
BufferUnordered | Stream for the |
Buffered | Stream for the |
Chain | Stream for the |
Chunks | Stream for the |
Collect | Future for the |
Concat | Future for the |
Cycle | Stream for the |
Empty | Stream for the |
Enumerate | Stream for the |
ErrInto | Stream for the |
Filter | Stream for the |
FilterMap | Stream for the |
FlatMap | Stream for the |
Flatten | Stream for the |
Fold | Future for the |
ForEach | Future for the |
ForEachConcurrent | Future for the |
Forward | Future for the |
Fuse | Stream for the |
FuturesOrdered | An unbounded queue of futures. |
FuturesUnordered | A set of futures which may complete in any order. |
Inspect | Stream for the |
InspectErr | Stream for the |
InspectOk | Stream for the |
IntoStream | Stream for the |
Iter | Stream for the |
Map | Stream for the |
MapErr | Stream for the |
MapOk | Stream for the |
Next | Future for the |
Once | A stream which emits single element and then EOF. |
OrElse | Stream for the |
Peek | Future for the |
Peekable | A |
Pending | Stream for the |
PollFn | Stream for the |
ReadyChunks | Stream for the |
Repeat | Stream for the |
RepeatWith | An stream that repeats elements of type |
ReuniteError | Error indicating a |
Scan | Stream for the |
Select | Stream for the |
SelectAll | An unbounded set of streams |
SelectNextSome | Future for the |
Skip | Stream for the |
SkipWhile | Stream for the |
SplitSink | A |
SplitStream | A |
StreamFuture | Future for the |
Take | Stream for the |
TakeUntil | Stream for the |
TakeWhile | Stream for the |
Then | Stream for the |
TryBufferUnordered | Stream for the
|
TryBuffered | Stream for the |
TryCollect | Future for the |
TryConcat | Future for the |
TryFilter | Stream for the |
TryFilterMap | Stream for the |
TryFlatten | Stream for the |
TryFold | Future for the |
TryForEach | Future for the |
TryForEachConcurrent | Future for the
|
TryNext | Future for the |
TrySkipWhile | Stream for the |
TryTakeWhile | Stream for the |
TryUnfold | Stream for the |
Unfold | Stream for the |
Unzip | Future for the |
Zip | Stream for the |
Traits
FusedStream | A stream which tracks whether or not the underlying stream should no longer be polled. |
Stream | A stream of values produced asynchronously. |
StreamExt | An extension trait for |
TryStream | A convenience for streams that return |
TryStreamExt | Adapters specific to |
Functions
empty | Creates a stream which contains no elements. |
iter | Converts an |
once | Creates a stream of a single element. |
pending | Creates a stream which never returns any elements. |
poll_fn | Creates a new stream wrapping a function returning |
repeat | Create a stream which produces the same item repeatedly. |
repeat_with | Creates a new stream that repeats elements of type |
select | This function will attempt to pull items from both streams. Each stream will be polled in a round-robin fashion, and whenever a stream is ready to yield an item that item is yielded. |
select_all | Convert a list of streams into a |
try_unfold | Creates a |
unfold | Creates a |
Type Definitions
BoxStream | An owned dynamically typed |
LocalBoxStream |
|