Modulesยง
- buffered_
with_ ๐fence - misc ๐
- pausable ๐
Structsยง
- Attached
Future - Attach an item of type
T
to the futureF
. 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ยง
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.