Expand description
Asynchronous streams
This module contains the Stream trait and a number of adaptors for this
trait. This trait is very similar to the Iterator trait in the standard
library except that it expresses the concept of blocking as well. A stream
here is a sequential sequence of values which may take some amount of time
in between to produce.
A stream may request that it is blocked between values while the next value is calculated, and provides a way to get notified once the next value is ready as well.
You can find more information/tutorials about streams online at https://tokio.rs
Re-exports
pub use self::futures_unordered::FuturesUnordered;Modules
An unbounded set of futures.
Structs
A stream combinator which chains a computation onto values produced by a stream.
An adaptor for a stream of futures to execute the futures concurrently, if possible, delivering results as they become available.
An adaptor for a stream of futures to execute the futures concurrently, if possible.
Stream for the catch_unwind combinator.
An adapter for chaining the output of two streams.
An adaptor that chunks up elements in a vector.
A future which collects all of the values of a stream into a vector.
A stream combinator to concatenate the results of a stream into the first yielded item.
A stream combinator to concatenate the results of a stream into the first yielded item.
A stream which contains no elements.
A stream combinator used to filter the results of a stream and only yield some values.
A combinator used to filter the results of a stream and simultaneously map them to a different type.
A combinator used to flatten a stream-of-streams into one long stream of elements.
A future used to collect all the results of a stream into one generic type.
A stream combinator which executes a unit closure over each item on a stream.
Future for the Stream::forward combinator, which sends a stream of values
to a sink and then waits until the sink has fully flushed those values.
A stream combinator to change the error type of a stream.
A stream which “fuse“s a stream once it’s terminated.
An unbounded queue of futures.
Do something with the items of a stream, passing it on.
Do something with the error of a stream, passing it on.
A stream which is just a shim over an underlying instance of Iterator.
A stream which is just a shim over an underlying instance of Iterator.
A stream which is just a shim over an underlying instance of Iterator.
A stream which is just a shim over an underlying instance of Iterator.
A stream combinator which will change the type of a stream from one type to another.
A stream combinator which will change the error type of a stream from one type to another.
An adapter for merging the output of two streams.
A stream which emits single element and then EOF.
A stream combinator which chains a computation onto errors produced by a stream.
A Stream that implements a peek method.
A stream which adapts a function returning Poll.
Stream that produces the same element repeatedly.
Error indicating a SplitSink<S> and SplitStream<S> were not two halves
of a Stream + Split, and thus could not be reunited.
An adapter for merging the output of two streams.
A stream combinator which skips a number of elements before continuing.
A stream combinator which skips elements of a stream while a predicate holds.
A Sink part of the split pair
A Stream part of the split pair
A combinator used to temporarily convert a stream into a future.
A stream combinator which returns a maximum number of elements.
A stream combinator which takes elements from a stream while a predicate holds.
A stream combinator which chains a computation onto each item produced by a stream.
A stream which creates futures, polls them and return their result
A stream combinator which converts an asynchronous stream to a blocking iterator.
An adapter for merging the output of two streams.
Enums
An item returned from a merge stream, which represents an item from one or both of the underlying streams.
Traits
A stream of values, not all of which may have been produced yet.
Functions
Creates a stream which contains no elements.
Converts a list of futures into a Stream of results from the futures.
Converts a list of futures into a Stream of results from the futures.
Converts an Iterator over Results into a Stream which is always ready
to yield the next value.
Converts an Iterator into a Stream which is always ready
to yield the next value.
Converts an Iterator over Results into a Stream which is always ready
to yield the next value.
Creates a stream of single element
Creates a new stream wrapping around a function returning Poll.
Create a stream which produces the same item repeatedly.
Creates a Stream from a seed and a closure returning a Future.