[−][src]Crate transform_stream
Lightweight async stream wrapper.
Usage
use transform_stream::{try_stream, AsyncTryStream}; use futures::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 { futures::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()); });
Macros
boxed_stream | Create a new boxed stream |
boxed_try_stream | Create a new boxed try stream |
stream | Create a new stream |
try_stream | Create a new try stream |
Structs
AsyncStream | Asynchronous stream of items |
AsyncTryStream | Asynchronous stream of results |
Yielder | A handle for sending items into the related stream. |