Struct RpcBatcher 

pub struct RpcBatcher {
    pub max_batch_bytes: usize,
}

Combines multiple RpcCalls into a single packet payload when possible.

Wire format for a batch:

[count: u8]  [call_1][call_2]...[call_N]

Fields

max_batch_bytes: usize

Maximum payload bytes before starting a new batch packet.

Implementations

impl RpcBatcher

pub fn new(max_batch_bytes: usize) -> Self

pub fn batch(&self, calls: &[RpcCall]) -> Vec<Vec<u8>>

Split calls into batches that each fit within max_batch_bytes. Returns a vector of serialised batch payloads.

pub fn unbatch(&self, payload: &[u8]) -> Result<Vec<RpcCall>, RpcError>

Deserialise a batch payload into RpcCalls.

Trait Implementations

impl Default for RpcBatcher

fn default() -> Self

Returns the “default value” for a type.