Crate future_utils[−][src]
Modules
bi_channel | |
mpsc |
channels in the futures-rs crate cannot error, yet they return () for their error type for some stupid reason. This is a wrapper around futures-rs unbounded channels which removes the error. |
Structs
DropNotice |
Created in tandem with a |
DropNotify |
Created in tandem with a |
Finally |
Wraps a stream or future and runs a callback when the stream/future ends or when |
Finish |
Future yielded by |
FirstOk |
Adapts a stream to a future by taking the first successful item yielded by the stream. If the
stream ends before yielding an |
FirstOk2 | |
FramedUnbuffered |
An alternative to tokio_io's |
Infallible |
Wraps a future or stream which can't fail (ie. has error type |
LogError |
Wraps a future which returns |
LogErrors |
Removes the errors from a stream and logs them. |
NextOrElse |
Takes the next item from the stream. If the stream ends then the provided callback is used to generate an error. |
ResumeUnwind |
Propogates the result of a |
ThreadFuture |
Wraps a synchronous function into a future by running it in its own thread. Created using
|
Timeout | |
Until |
Runs a stream or future until some condition is met. |
WhileDriving | |
WithReadinessTimeout | |
WithTimeout |
Enums
FinishInner |
Traits
FutureExt |
Extension trait for |
StreamExt |
Extension trait for |
Functions
drop_notify |
Create a ( |
thread_future |
Run a synchronous function in a separate thread and return its result as a |
Type Definitions
BoxFuture | |
BoxSink | |
BoxStream | |
IoFuture | |
IoSink | |
IoStream |