This module contains:
A handle to an
A registration handle for an
Abortabletask. Values of this type can be acquired from
AbortHandle::newand are used in calls to
A future/stream which can be remotely short-circuited using an
Indicator that the
Abortabletask was aborted.
An unbounded queue of futures.
A set of futures which may complete in any order.
A stream which emits single element and then EOF.
Streamthat implements a
An stream that repeats elements of type
Aendlessly by applying the provided closure
F: FnMut() -> A.
Error indicating a
SplitStream<S>were not two halves of a
Stream + Split, and thus could not be
An unbounded set of streams
Sinkpart of the split pair
Streampart of the split pair
Error indicating, that while chunk was collected inner stream produced an error.
A stream which tracks whether or not the underlying stream should no longer be polled.
A stream of values produced asynchronously.
An extension trait for
Streams that provides a variety of convenient combinator functions.
A convenience for streams that return
Resultvalues that includes a variety of adapters tailored to such futures.
Adapters specific to
Creates a new
Abortablestream and an
AbortHandlewhich can be used to stop it.
Creates a stream which contains no elements.
Streamwhich is always ready to yield the next value.
Creates a stream of a single element.
Creates a stream which never returns any elements.
Creates a new stream wrapping a function returning
Create a stream which produces the same item repeatedly.
Creates a new stream that repeats elements of type
Aendlessly by applying the provided closure, the repeater,
F: FnMut() -> A.
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.
Convert a list of streams into a
Streamof results from the streams.
This function will attempt to pull items from both streams. You provide a closure to tell
SelectWithStrategywhich stream to poll. The closure can store state on
SelectWithStrategyto which it will receive a
&muton every invocation. This allows basing the strategy on prior choices.
TryStreamfrom a seed and a closure returning a
Streamfrom a seed and a closure returning a