Struct AuthenticatedSession 

struct AuthenticatedSession {
    _proof: WebSocketAuth,
    writer: SplitSink<WebSocket, Message>,
    reader: SplitStream<WebSocket>,
    outbound: UserOutboundReceiver,
    user: User,
    user_config: UserConfig,
    metrics: Arc<RuntimeMetrics>,
    shutdown: CancellationToken,
}

Fields

_proof: WebSocketAuth

writer: SplitSink<WebSocket, Message>

reader: SplitStream<WebSocket>

outbound: UserOutboundReceiver

user: User

user_config: UserConfig

metrics: Arc<RuntimeMetrics>

shutdown: CancellationToken

Implementations

impl AuthenticatedSession

async fn serve(self)

fn record_current_span(&self)

async fn start(self) -> Option<Self>

async fn start_inner(&mut self) -> Result<(), SessionExit>

async fn finish(&mut self, exit: SessionExit)

fn shutdown_exit(&self) -> Option<SessionExit>

async fn run_loop(&mut self) -> SessionExit

Checks transport health before each ping so RTC teardown closes idle sessions.

fn check_transport(&self) -> Option<SessionExit>

async fn handle_socket_event( &mut self, message: Option<Result<Message, AxumError>>, pong: &mut Option<Instant>, ) -> Option<SessionExit>

async fn handle_frame( &mut self, message: Message, pong: &mut Option<Instant>, ) -> Option<SessionExit>

async fn handle_binary(&mut self, payload: &[u8]) -> Option<SessionExit>

async fn handle_text(&mut self, payload: &str) -> Option<SessionExit>

async fn client_error(&self, fallback_code: CloseCode) -> SessionExit

async fn handle_outbound_event( &mut self, outbound: UserOutboundEvent, ) -> Option<SessionExit>

fn outbound_error(&self, code: CloseCode, log_send_failure: bool) -> SessionExit