3 releases (breaking)
0.3.0 | Nov 23, 2022 |
---|---|
0.2.0 | Nov 23, 2022 |
0.1.0 | May 23, 2022 |
#582 in Asynchronous
588 downloads per month
7KB
81 lines
Drop Stream
A stream that wraps another stream with a closure that is called once it is dropped. Very useful for libraries that use streams for data transfer and you need to connect when the opposite site drops the connection, thus dropping the stream.
This crate only depends on futures-core and thus is a minimal dependency, suitable for any type of project utilising futures.
Example
use futures::Stream;
use drop_stream::DropStream;
let test_stream = futures::stream::repeat(true);
{
let wrapped_stream = DropStream::new(test_stream, move || {
println!("Stream has been dropped!");
});
let mut wrapped_stream = Box::pin(wrapped_stream);
let waker = futures::task::noop_waker();
let mut context = futures::task::Context::from_waker(&waker);
assert_eq!(
wrapped_stream.as_mut().poll_next(&mut context),
std::task::Poll::Ready(Some(true))
);
}
Acknowledgement
I thank Aadam Zocolo for letting me take over the crate name "drop-stream" on crates.io and replace his 0.1 version.
Dependencies
~24KB