Crate rw_futures_util

Source

Modulesยง

buffered_with_fence ๐Ÿ”’
misc ๐Ÿ”’
pausable ๐Ÿ”’

Structsยง

AttachedFuture
Attach an item of type T to the future F. When the future is polled with ready, the item will be attached to the output of future as (F::Output, item).
Pausable
Valve
A valve is a handle that can control the Pausable stream.

Traitsยง

RwFutureExt
RwTryStreamExt

Functionsยง

await_future_with_monitor_error_stream
Await on a future while monitoring on a peekable stream that may return error. The peekable stream is polled at a higher priority than the future.
drop_either_future
pausable
Create a pausable stream, which can be paused or resumed by a valve.
pending_on_none
select_all
Convert a list of streams into a [Stream] of results from the streams.