Struct TestDeserializer 

pub struct TestDeserializer { /* private fields */ }

A scriptable Deserializer over owned byte-vector records.

Modes:

• passthrough: one record per payload;
• split_on: one record per delimiter-separated segment — exercises 1→N fan-out (b"a,b" → ["a", "b"]; empty segments are emitted, so b"a,,b" yields three records);
• fail_on_prefix: payloads starting with the marker fail with DeserError::Malformed, everything else passes through — exercises Skip/Fail error policies.

Emission honors Flow::Blocked: the deserializer stops emitting for the current payload, as the seam contract requires.

Implementations

impl TestDeserializer

pub fn passthrough() -> Self

One record per payload.

pub fn split_on(delimiter: u8) -> Self

One record per delimiter-separated segment of the payload.

pub fn fail_on_prefix(marker: impl Into<Vec<u8>>) -> Self

Fail payloads starting with marker; pass the rest through.

Trait Implementations

impl Clone for TestDeserializer

fn clone(&self) -> TestDeserializer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TestDeserializer

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

Formats the value using the given formatter.

impl Deserializer<Owned<Vec<u8>>> for TestDeserializer

fn deserialize<'buf>( &mut self, raw: &RawPayload<'buf>, ack: &AckRef, out: &mut dyn EmitRecord<'buf, Vec<u8>>, ) -> Result<(), DeserError>

Decode raw, emitting each resulting record with the payload’s metadata and a clone of ack.