Struct RpcQueue 

pub struct RpcQueue { /* private fields */ }

Accumulates outgoing RPC calls for batched network dispatch.

Implementations

impl RpcQueue

pub fn new(max_len: usize) -> Self

pub fn enqueue(&mut self, call: RpcCall)

Add an RPC call to the queue. Assigns a sequence number.

pub fn drain(&mut self) -> impl Iterator<Item = RpcCall> + '_

Drain all pending calls.

pub fn peek(&self) -> Option<&RpcCall>

Peek at the front without removing.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn clear(&mut self)