Crate rw_futures_util

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.