Struct ValueStreamWriter 

pub struct ValueStreamWriter<'a> {
    pub inner: &'a mut BufferWriter,
}

Stream API for ValueBase wire marshalling (CDR §15.3.4).

Phase 1: API skeleton that wraps zerodds_cdr::BufferReader/Writer and applies the value-tag logic (chunked encoding, repository-id list). Phase 2 wires the full spec conformance (truncatable, custom marshaling, codeset).

Fields

inner: &'a mut BufferWriter

Inner writer.

Implementations

impl<'a> ValueStreamWriter<'a>

pub fn new(inner: &'a mut BufferWriter) -> Self

Constructor.

pub fn write_value_tag( &mut self, repository_id: &str, ) -> Result<(), EncodeError>

Writes a value-tag (CDR §15.3.4.2). Format: 0x7FFFFF02 for single-repository-id, 0x7FFFFF06 for list-of-repository- ids, 0x00000000 for null-value.

Errors

Encode error.

pub fn write_value_tag_multi( &mut self, repository_ids: &[&str], ) -> Result<(), EncodeError>

Writes a value-tag with a multi-repository-id list (CDR §15.3.4.2). Wire tag = 0x7FFF_FF06 (list-of-repository-ids + no chunked bit). Layout:

u32 tag = 0x7FFFFF06
i32 count                 // > 0
string id[0] .. id[N-1]   // CDR-strings (length + bytes + NUL)

Errors

Encode error or empty repository_ids (spec requires N >= 1).

pub fn write_chunked_value_tag( &mut self, repository_ids: &[&str], ) -> Result<(), EncodeError>

Writes a chunked value-tag (CDR §15.3.4.2 + §15.3.4.3 — “chunked encoding”). Wire tag = 0x7FFF_FF0A (chunked flag + multi-repo-id flag, both set).

After the tag come:

1. i32 count + string id[N] (multi-repo-id-list).
2. Per chunk: i32 chunk_size_bytes + octet chunk_data[..].
3. Finally: i32 end_tag = -<nesting_level> (Spec §15.3.4.3 negative-level marker).

This function writes the tag header + repo IDs; the caller layer writes each chunk via Self::write_chunk and closes the ValueType with Self::write_chunked_end.

Errors

Encode error or empty repo IDs.

pub fn write_chunk(&mut self, chunk_data: &[u8]) -> Result<(), EncodeError>

Writes a single chunk within a chunked-encoded value (CDR §15.3.4.3): i32 chunk_size + raw bytes.

Errors

Encode error.

pub fn write_chunked_end( &mut self, nesting_level: u32, ) -> Result<(), EncodeError>

Writes the end-tag of a chunked-encoded value (Spec §15.3.4.3 — i32 end_tag = -<nesting_level> with nesting_level >= 1 for the outermost value).

Errors

Encode error or nesting_level == 0.