Struct ChunkWriter 

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

Writes raw chunks to an AsyncWrite transport.

ChunkWriter::write_chunk writes the 5-byte header then the payload (if non-empty), then flushes. ChunkWriter::write_stdin, ChunkWriter::write_ctrl_in_json, and ChunkWriter::write_ctrl_out_json are convenience helpers for the most common write paths.

Every write validates before touching the transport: a stream_type above 4 or a payload longer than MAX_CHUNK_LEN returns RawError::InvalidStreamType / RawError::ChunkTooLarge instead of writing a header the peer cannot frame (a truncated u32 length would corrupt the stream). An empty payload writes the same header as a zero-length payload — every helper takes &[u8]-shaped input and emits length == 0 with no payload bytes.

Implementations

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

pub fn new(writer: W) -> Self

Wrap an AsyncWrite transport in a chunk writer.

pub fn into_inner(self) -> W

Consume the writer and return the underlying transport.

pub async fn write_chunk(&mut self, chunk: &Chunk) -> Result<(), RawError>

Write a chunk: header + payload (if non-empty) + flush. The chunk’s stream_type and payload length are validated first — an invalid chunk fails locally with RawError::InvalidStreamType or RawError::ChunkTooLarge instead of corrupting the peer’s framing.

pub async fn write_stdin(&mut self, bytes: &[u8]) -> Result<(), RawError>

Write a stdin chunk (stream_type 0) directly from a byte slice. An empty slice writes the zero-length EOF sentinel.

pub async fn write_ctrl_in_json(&mut self, json: &[u8]) -> Result<(), RawError>

Write a client→server control chunk (stream_type 3) carrying a JSON payload (Resize, Signal, or Eof).

pub async fn write_ctrl_out_json(&mut self, json: &[u8]) -> Result<(), RawError>

Write a server→client control chunk (stream_type 4) carrying a JSON payload (Exit).