Struct SessionActor 

pub struct SessionActor<M> { /* private fields */ }

Handle to a dedicated session actor.

The mailbox is bounded so producers apply backpressure instead of growing memory without limit. The actor has its own thread; callers on Tokio worker threads use Self::send and await capacity rather than blocking workers.

Implementations

impl<M: Send + 'static> SessionActor<M>

pub fn spawn<F, Fut>(capacity: usize, handler: F) -> Self

where F: FnMut(M) -> Fut + Send + 'static, Fut: Future<Output = ()> + Send + 'static,

pub async fn send(&self, message: M) -> Result<(), SendError<M>>

pub fn blocking_send(&self, message: M) -> Result<(), SendError<M>>

Used only by synchronous facade methods called outside a Tokio worker.

Trait Implementations

impl<M: Send + 'static> Clone for SessionActor<M>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M: Debug> Debug for SessionActor<M>

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

Formats the value using the given formatter.