1 unstable release
0.1.0 | Feb 21, 2022 |
---|
#1810 in Asynchronous
11KB
95 lines
Crate repeating_future
This crate allows you to make any [Future] to a futures::Stream by yielding the futures' result when its ready and calling it over and over again to endlessly produce results.
With the default-enabled feature streams
this crate provides a handy [FutureStream] which makes a futures::Stream out
of any [Future] and streams the results of that [Future] until the underlying future fails.
Look at the stream-example to see how easy life can get. Its a sub-50-lines file which completely converts rumqttc to a futures::Stream.
With disabled feature streams
it anyhow defines helpers and a final [RepeatingFuture] that
constructs a [Future] which gets a [Future] from a function of an object and forwards its result. When the underlying function is Poll::Ready, the function-future is acquired again.
It can be used iE for streaming items from an async
-function that just delivers one
result per call.
This crate was originally made to extend the terrific rumqttc MQTT-client to support futures::Stream. So all examples are made for this for the moment.
Usage
Add this crate to your Cargo.toml
repeating_future = "0.1.0"
and use it in your main.rs:
use repeating_future::FutureStream;
Easy example
See Example Or for a manual Stream implementation: Example
Try cargo run --example manual
or cargo run --example stream
Dependencies
~0.8–16MB
~161K SLoC