Struct FramedWriter 

pub struct FramedWriter<W: AsyncWrite + Unpin> { /* private fields */ }

Async writer that frames Crous data into blocks over a Tokio stream.

Implementations

impl<W: AsyncWrite + Unpin> FramedWriter<W>

pub fn new(writer: W) -> Self

pub fn with_flags(writer: W, flags: u8) -> Self

pub async fn write_block(&mut self, block: &[u8]) -> Result<()>

Write a pre-built block.

pub async fn write_data(&mut self, payload: &[u8]) -> Result<()>

Write a raw data payload as a framed block.

pub async fn flush(&mut self) -> Result<()>

Flush the underlying writer.

pub fn into_inner(self) -> W

Consume the writer and return the inner stream.