6 releases
new 0.3.1 | Jan 18, 2025 |
---|---|
0.3.0 | Feb 1, 2023 |
0.2.0 | Oct 13, 2021 |
0.1.2 | Oct 22, 2020 |
#329 in Asynchronous
3,724 downloads per month
Used in 12 crates
(4 directly)
11KB
280 lines
transform-stream
Lightweight async stream wrapper
Documentation: https://docs.rs/transform-stream
Inspired by https://github.com/tokio-rs/async-stream
Contributing
lib.rs
:
Lightweight async stream wrapper.
Inspired by https://github.com/tokio-rs/async-stream
Usage
use transform_stream::{try_stream, AsyncTryStream};
use futures_util::{pin_mut, StreamExt};
use std::io;
let stream: AsyncTryStream<Vec<u8>, io::Error, _> = try_stream!{
yield_!(vec![b'1', b'2']);
yield_!(vec![b'3', b'4']);
Ok(())
};
futures_executor::block_on(async {
pin_mut!(stream);
assert_eq!(stream.next().await.unwrap().unwrap(), vec![b'1', b'2']);
assert_eq!(stream.next().await.unwrap().unwrap(), vec![b'3', b'4']);
assert!(stream.next().await.is_none());
});
Dependencies
~25KB