Struct AsyncStreamReader 

pub struct AsyncStreamReader { /* private fields */ }

An async cursor over one live output stream, the awaiting counterpart of StreamReader. AsyncStreamReader::next yields the next chunk without parking a runtime thread, so many streams can be read on one event loop.

Implementations

impl AsyncStreamReader

pub async fn next(&mut self) -> Option<Vec<u8>>

The next retained chunk of raw bytes, or None once the stream is closed and fully drained. A reader that falls more than the buffer cap behind skips the dropped head rather than stalling.

pub fn into_stream(self) -> BoxStream<'static, Vec<u8>>

Consume the reader into a futures::Stream of raw byte chunks, for StreamExt combinators and select!:

use futures::StreamExt;
let mut stdout = process.reader_async(sail::exec::OutputStream::Stdout).into_stream();
while let Some(chunk) = stdout.next().await {
    print!("{}", String::from_utf8_lossy(&chunk));
}

Trait Implementations

impl Debug for AsyncStreamReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.