Struct FrameRouter 

pub struct FrameRouter { /* private fields */ }

Allocates message ids and queues inbound server frames for a connection.

Implementations

impl FrameRouter

pub fn fresh_msg_id(&self) -> u64

Allocates and returns the next unique message id.

pub fn peek_next_msg_id(&self) -> u64

Returns the message id the next FrameRouter::fresh_msg_id call would produce, without consuming it.

pub fn push_inbound(&self, frame: ServerFrame) -> Result<()>

Pushes a frame onto the back of the inbound queue.

Returns Error::PoisonedLock rather than panicking when the queue mutex is poisoned, matching the sibling server locks.

pub fn pop_inbound(&self) -> Result<Option<ServerFrame>>

Pops the next frame from the front of the inbound queue, if any.

Returns Error::PoisonedLock rather than panicking when the queue mutex is poisoned, matching the sibling server locks.

Trait Implementations

impl Default for FrameRouter

fn default() -> FrameRouter

Returns the “default value” for a type.