Struct ServerSession 

pub struct ServerSession<P: Protocol, S: ServerState> { /* private fields */ }

A typed server-side reflector session.

P is the protocol marker (crate::session::client::DExtra, crate::session::client::DPlus, crate::session::client::Dcs). S is the server state marker (super::Unknown, super::Link1Received, super::Linked, etc.).

Implementations

impl<P: Protocol, S: ServerState> ServerSession<P, S>

pub const fn state_kind(&self) -> ServerStateKind

Runtime state discriminator.

pub const fn peer(&self) -> SocketAddr

Peer address.

pub fn pop_event(&mut self) -> Option<ServerEvent<P>>

Drain the next server event.

impl<P: Protocol> ServerSession<P, Streaming>

pub fn handle_voice_data( self, now: Instant, bytes: &[u8], ) -> Result<Self, Error>

Process a voice data packet on a streaming client.

Only available when S = Streaming — calling this in any other state is a compile error.

Errors

Returns any Error the core propagates while processing the event.

impl ServerSession<DPlus, Link1Received>

pub fn handle_link2( self, now: Instant, _callsign: Callsign, bytes: &[u8], ) -> Result<ServerSession<DPlus, Linked>, Error>

Process a DPlus LINK2 packet after a LINK1 has been received.

Only available on ServerSession<DPlus, Link1Received> — calling this before LINK1 (in the super::Unknown state) is a compile error.

Errors

Returns any Error the core propagates.

impl<P: Protocol> ServerSession<P, Linked>

pub fn handle_unlink( self, now: Instant, bytes: &[u8], ) -> Result<ServerSession<P, Closed>, Error>

Process an UNLINK packet on a linked client.

Only available on ServerSession<P, Linked> — calling this after the session has already reached Closed is a compile error.

Errors

Returns any Error the core propagates.

Trait Implementations

impl<P: Debug + Protocol, S: Debug + ServerState> Debug for ServerSession<P, S>

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

Formats the value using the given formatter.