Struct StreamWriter 

pub struct StreamWriter { /* private fields */ }

The write end of a byte stream. Bounded: write awaits when the buffer is full, so production can’t outrun a slow consumer. Dropping the writer ends the stream (the reader then sees None).

Implementations

impl StreamWriter

pub async fn write(&self, chunk: Vec<u8>) -> Result<(), Vec<u8>>

Writes one chunk, awaiting if the buffer is full (back-pressure). Returns the chunk back in Err if the reader has gone away.

Trait Implementations

impl Clone for StreamWriter

fn clone(&self) -> StreamWriter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamWriter

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

Formats the value using the given formatter.