Struct BinaryResponseBodyChunkEvent 

pub struct BinaryResponseBodyChunkEvent {
    pub correlation_id: String,
    pub data: Bytes,
    pub is_last: bool,
    pub total_size: Option<usize>,
    pub chunk_index: u32,
    pub bytes_sent: usize,
}

Binary response body chunk event.

This type uses Bytes for zero-copy body streaming, avoiding the base64 encode/decode overhead of ResponseBodyChunkEvent. Use this type for:

• Binary UDS transport (with binary-uds feature)
• gRPC transport (protobuf already uses bytes)
• Any transport that supports raw binary data

For JSON transport, use ResponseBodyChunkEvent with base64-encoded data.

Fields

correlation_id: String

Correlation ID

data: Bytes

Body chunk data (raw bytes, no encoding)

is_last: bool

Is this the last chunk?

total_size: Option<usize>

Total body size if known

chunk_index: u32

Chunk index for ordering (0-based)

bytes_sent: usize

Bytes sent so far (cumulative)

Implementations

impl BinaryResponseBodyChunkEvent

pub fn new( correlation_id: impl Into<String>, data: impl Into<Bytes>, chunk_index: u32, is_last: bool, ) -> Self

Create a new binary response body chunk event.

pub fn with_total_size(self, size: usize) -> Self

Set the total body size.

pub fn with_bytes_sent(self, bytes: usize) -> Self

Set cumulative bytes sent.

Trait Implementations

impl Clone for BinaryResponseBodyChunkEvent

fn clone(&self) -> BinaryResponseBodyChunkEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BinaryResponseBodyChunkEvent

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

Formats the value using the given formatter.

impl From<&ResponseBodyChunkEvent> for BinaryResponseBodyChunkEvent

fn from(event: &ResponseBodyChunkEvent) -> Self

Convert base64-encoded body chunk to binary type.

If base64 decoding fails, falls back to treating data as raw UTF-8 bytes.

impl From<BinaryResponseBodyChunkEvent> for ResponseBodyChunkEvent

fn from(event: BinaryResponseBodyChunkEvent) -> Self

Convert binary body chunk to base64-encoded JSON-compatible type.