Struct SocketStateSink 

pub struct SocketStateSink { /* private fields */ }

Receives ordered semantic state changes from a single socket client.

Clients must route every transition into or out of ConnectionMode::Active through the sink-backed transition methods so each edge is reported once.

Implementations

impl SocketStateSink

pub fn new<F>(callback: F) -> Self

where F: Fn(SocketState) + Send + Sync + 'static,

Creates a new SocketStateSink instance.

The callback runs synchronously with each successful state transition and should return promptly. It must not initiate another transition using the same sink because callbacks are serialized under a non-reentrant lock.

pub fn with_callback<F>(self, callback: F) -> Self

where F: Fn(SocketState) + Send + Sync + 'static,

Returns a sink that invokes callback before forwarding each state to this sink.

Trait Implementations

impl Clone for SocketStateSink

fn clone(&self) -> SocketStateSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SocketStateSink

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

Formats the value using the given formatter.