Struct SessionServer 

pub struct SessionServer { /* private fields */ }

Manages all streaming client sessions.

Implementations

impl SessionServer

pub fn new( port: u16, buffer_ms: i32, auth: Option<Arc<dyn AuthValidator>>, ) -> Self

Create a new session server.

pub async fn push_settings(&self, update: ClientSettingsUpdate)

Push a settings update to a specific streaming client.

pub async fn run( &self, chunk_rx: Sender<WireChunkData>, codec: String, codec_header: Vec<u8>, event_tx: Sender<ServerEvent>, ) -> Result<()>

Run the session server — accepts connections and spawns per-client tasks.

pub async fn connected_clients(&self) -> Vec<ClientInfo>

Get list of connected clients.