Struct BinaryRequestBodyChunkEvent 

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

Binary request body chunk event.

This type uses Bytes for zero-copy body streaming, avoiding the base64 encode/decode overhead of RequestBodyChunkEvent. 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 RequestBodyChunkEvent 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_received: usize

Bytes received so far (cumulative)

Implementations

impl BinaryRequestBodyChunkEvent

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

Create a new binary request body chunk event.

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

Set the total body size.

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

Set cumulative bytes received.

Trait Implementations

impl Clone for BinaryRequestBodyChunkEvent

fn clone(&self) -> BinaryRequestBodyChunkEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BinaryRequestBodyChunkEvent

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

Formats the value using the given formatter.

impl From<&RequestBodyChunkEvent> for BinaryRequestBodyChunkEvent

fn from(event: &RequestBodyChunkEvent) -> 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<BinaryRequestBodyChunkEvent> for RequestBodyChunkEvent

fn from(event: BinaryRequestBodyChunkEvent) -> Self

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