Struct WsConn 

pub struct WsConn { /* private fields */ }

A per-connection WebSocket actor that bridges Gun protocol messages.

Created by crate::adapters::WsServer (inbound) or crate::adapters::OutgoingWebsocketManager (outbound). Each WsConn manages a single WebSocket connection and translates between the Gun wire format (text) and [Message] enum values.

Implementations

impl WsConn

pub fn new( sender: SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>, receiver: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, allow_public_space: bool, ) -> Self

Creates a new WsConn from the split halves of a WebSocket stream.

Arguments

• sender - The writing half of the WebSocket stream
• receiver - The reading half of the WebSocket stream
• allow_public_space - Whether to accept public space writes (forwarded to Message::try_from for inbound message parsing)

Trait Implementations

impl Actor for WsConn

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: Message, _ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle an incoming message.

fn pre_start<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once before the actor starts processing messages.

fn stopping<'life0, 'life1, 'async_trait>( &'life0 mut self, _context: &'life1 ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called once after the actor’s message loop exits.

fn subscribe_to_everything(&self) -> bool

Whether this actor wants to receive all messages (not just addressed to it). Used by the Multicast adapter.

fn try_clone_storage(&self) -> Option<Box<dyn Actor>>

Attempts to produce a clone of this actor for storage read/write splitting.