Struct tokio_util::io::ReaderStream [−][src]
pub struct ReaderStream<R> { /* fields omitted */ }
This is supported on crate feature
io
only.Expand description
Convert an AsyncRead
into a Stream
of byte chunks.
This stream is fused. It performs the inverse operation of
StreamReader
.
Example
use tokio_stream::StreamExt;
use tokio_util::io::ReaderStream;
// Create a stream of data.
let data = b"hello, world!";
let mut stream = ReaderStream::new(&data[..]);
// Read all of the chunks into a vector.
let mut stream_contents = Vec::new();
while let Some(chunk) = stream.next().await {
stream_contents.extend_from_slice(&chunk?);
}
// Once the chunks are concatenated, we should have the
// original data.
assert_eq!(stream_contents, data);
Implementations
Trait Implementations
Attempt to pull out the next value of this stream, registering the
current task for wakeup if the value is not yet available, and returning
None
if the stream is exhausted. Read more