Struct RpcRequestChunkPayload 

pub struct RpcRequestChunkPayload {
    pub call_id: u64,
    pub flags: u16,
    pub headers: Vec<RpcHeader>,
    pub body: Bytes,
}

Continuation chunk for a client-streaming or duplex REQUEST. Lives after the 24-byte EventMeta prefix in a DISPATCH_RPC_REQUEST_CHUNK event.

Unlike the initial RpcRequestPayload there is no service field (server already routed by service at the initial REQUEST) and no deadline_ns (the initial REQUEST’s deadline applies to the whole call). The call_id field is redundant with EventMeta::seq_or_ts but kept on the payload so the codec is self-contained — a reader handed a chunk’s bytes without the meta header can still recover its correlation id.

Bidi streaming plan (Phase A).

Fields

call_id: u64

Matches EventMeta::seq_or_ts and the original REQUEST’s call_id. Kept on the payload so the codec round-trips in isolation.

flags: u16

Bitfield of FLAG_RPC_* constants. The only flag that makes sense on a chunk today is FLAG_RPC_REQUEST_END; other flags MUST be zero on the wire so future protocol extensions can claim them without colliding with existing chunks.

headers: Vec<RpcHeader>

Per-chunk metadata. Typically empty; reserved for trace-span continuity across long uploads, content-type changes mid-stream, or other rare per-chunk concerns. Capped at MAX_RPC_HEADERS entries with the same per-field caps as RpcRequestPayload::headers.

body: Bytes

Application-defined chunk body. Cap is MAX_RPC_BODY_LEN (4 MiB), same as the initial REQUEST body — clients that need >4 MiB total payload chunk their upload across multiple REQUEST_CHUNK events.

See RpcRequestPayload::body for the Bytes-vs-Vec<u8> rationale.

Implementations

impl RpcRequestChunkPayload

pub fn encoded_len(&self) -> usize

Compute the encoded byte length WITHOUT actually encoding. See RpcRequestPayload::encoded_len for the rationale.

pub fn encode(&self) -> Vec<u8>

Encode to the wire bytes that follow the 24-byte EventMeta prefix in a DISPATCH_RPC_REQUEST_CHUNK event. Same encoder-bounds policy as RpcRequestPayload::encode: oversize fields panic in debug, the decoder enforces in release.

pub fn decode(data: Bytes) -> Result<Self, RpcCodecError>

Decode from the wire bytes following the EventMeta prefix. Bounded by the same MAX_RPC_* caps as the initial REQUEST. Takes Bytes for zero-copy body slicing — see perf #84.

Trait Implementations

impl Clone for RpcRequestChunkPayload

fn clone(&self) -> RpcRequestChunkPayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RpcRequestChunkPayload

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

Formats the value using the given formatter.

impl Eq for RpcRequestChunkPayload

impl PartialEq for RpcRequestChunkPayload

fn eq(&self, other: &RpcRequestChunkPayload) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RpcRequestChunkPayload