Crate future_utils [−] [src]
Modules
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 |
FirstOk |
Adapts a stream to a future by taking the first successful item yielded by the stream. If the
stream ends before yielding an |
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. |
Until |
Runs a stream or future until some condition is met. |
Traits
FutureExt |
Extension trait for |
StreamExt |
Extension trait for |
Functions
drop_notify |
Create a ( |
Type Definitions
BoxFuture | |
BoxSink | |
BoxStream | |
IoFuture | |
IoSink | |
IoStream |