Struct SessionFacade 

pub struct SessionFacade<'a, H: SessionFacadeHandler> { /* private fields */ }

Session-id based facade over server events.

Implementations

impl<'a, H: SessionFacadeHandler> SessionFacade<'a, H>

pub fn new(server: &'a mut RaknetServer, handler: &'a mut H) -> Self

Creates a new session facade with an empty SessionIdAdapter.

pub fn with_adapter( server: &'a mut RaknetServer, handler: &'a mut H, adapter: SessionIdAdapter, ) -> Self

Creates a session facade with a caller-provided adapter.

pub async fn next(&mut self) -> Result<bool>

Polls one event and dispatches it to the session handler.

Returns Ok(false) when the server event stream is closed.

pub async fn run(&mut self) -> Result<()>

Runs facade loop until stream closure or callback error.

pub fn server(&self) -> &RaknetServer

Returns immutable access to wrapped server.

pub fn server_mut(&mut self) -> &mut RaknetServer

Returns mutable access to wrapped server.

pub fn handler(&self) -> &H

Returns immutable access to wrapped handler.

pub fn handler_mut(&mut self) -> &mut H

Returns mutable access to wrapped handler.

pub fn adapter(&self) -> &SessionIdAdapter

Returns immutable access to the session-id adapter.

pub fn adapter_mut(&mut self) -> &mut SessionIdAdapter

Returns mutable access to the session-id adapter.

pub fn session_id_for_peer(&self, peer_id: PeerId) -> Option<SessionId>

Resolves PeerId to session id.

pub fn peer_id_for_session(&self, session_id: SessionId) -> Option<PeerId>

Resolves session id to PeerId.

pub fn peer_id_for_session_i32(&self, session_id: i32) -> Option<PeerId>

Resolves i32 session id to PeerId.

pub async fn send( &mut self, session_id: SessionId, payload: impl Into<Bytes>, ) -> Result<()>

Sends payload to a session with default send options.

pub async fn send_with_options( &mut self, session_id: SessionId, payload: impl Into<Bytes>, options: SendOptions, ) -> Result<()>

Sends payload to a session with explicit send options.

pub async fn send_with_receipt( &mut self, session_id: SessionId, payload: impl Into<Bytes>, receipt_id: u64, ) -> Result<()>

Sends payload to a session and tracks a receipt id.

pub async fn disconnect(&mut self, session_id: SessionId) -> Result<()>

Disconnects a session.