Struct LoggerStream

pub struct LoggerStream { /* private fields */ }

A stream bound to a socket where a source stream is captured. For example, stdout and stderr streams can be redirected to the contained socket and captured.

Implementations

impl LoggerStream

pub fn new(socket: Socket) -> Result<LoggerStream, Status>

Create a LoggerStream from the provided zx::Socket. The socket object should be bound to its intended source stream (e.g. “stdout”).

pub async fn read_to_end(self) -> Result<Vec<u8>, LogError>

Reads all bytes from socket.

pub async fn buffer_drain_and_peek( self, writer: &mut SocketLogWriter, peek_fn: Option<impl Fn(&[u8])>, ) -> Result<(), LogError>

Drain the stream and write all of its contents to writer. Bytes are delimited by newline and each line will be passed to writer.write individually. An optional peek_fn may be specified which is passed a reference to each line before it is written.

pub async fn buffer_and_drain( self, writer: &mut SocketLogWriter, ) -> Result<(), LogError>

Convenience function for buffer_drain_and_peek without a peek function.

pub fn take_socket(self) -> Socket

Take the underlying socket of this object.

Trait Implementations

impl Unpin for LoggerStream