[−][src]Module futures_util::stream
Streams
This module contains a number of functions for working with Stream
s,
including the StreamExt
trait which adds methods to Stream
types.
Structs
BufferUnordered |
An adaptor for a stream of futures to execute the futures concurrently, if possible, delivering results as they become available. |
Buffered |
An adaptor for a stream of futures to execute the futures concurrently, if possible. |
CatchUnwind |
Stream for the |
Chain |
An adapter for chaining the output of two streams. |
Chunks |
An adaptor that chunks up elements in a vector. |
Collect |
A future which collects all of the values of a stream into a vector. |
Concat |
A stream combinator to concatenate the results of a stream into the first yielded item. |
Empty |
A stream which contains no elements. |
Filter |
A stream combinator used to filter the results of a stream and only yield some values. |
FilterMap |
A combinator used to filter the results of a stream and simultaneously map them to a different type. |
Flatten |
A combinator used to flatten a stream-of-streams into one long stream of elements. |
Fold |
A future used to collect all the results of a stream into one generic type. |
ForEach |
A stream combinator which executes a unit closure over each item on a stream. |
ForEachConcurrent |
A stream combinator which executes a unit closure over each item on a stream concurrently. |
Forward |
Future for the |
Fuse |
A stream which "fuse"s a stream once it's terminated. |
FuturesOrdered |
An unbounded queue of futures. |
FuturesUnordered |
A set of futures which may complete in any order. |
Inspect |
Do something with the items of a stream, passing it on. |
Iter |
A stream which is just a shim over an underlying instance of |
Map |
A stream combinator which will change the type of a stream from one type to another. |
Next |
A future of the next element of a stream. |
Once |
A stream which emits single element and then EOF. |
Peekable |
A |
PollFn |
A stream which adapts a function returning |
Repeat |
Stream that produces the same element repeatedly. |
ReuniteError |
Error indicating a |
Select |
An adapter for merging the output of two streams. |
Skip |
A stream combinator which skips a number of elements before continuing. |
SkipWhile |
A stream combinator which skips elements of a stream while a predicate holds. |
SplitSink |
A |
SplitStream |
A |
StreamFuture |
A combinator used to temporarily convert a stream into a future. |
Take |
A stream combinator which returns a maximum number of elements. |
TakeWhile |
A stream combinator which takes elements from a stream while a predicate holds. |
Then |
A stream combinator which chains a computation onto each item produced by a stream. |
Unfold |
A stream which creates futures, polls them and return their result |
Zip |
An adapter for merging the output of two streams. |
Traits
StreamExt |
An extension trait for |
Functions
empty |
Creates a stream which contains no elements. |
futures_ordered |
Converts a list of futures into a |
futures_unordered |
Converts a list of futures into a |
iter |
Converts an |
once |
Creates a stream of single element |
poll_fn |
Creates a new stream wrapping around a function returning |
repeat |
Create a stream which produces the same item repeatedly. |
unfold |
Creates a |