Struct WebSocketConnection 

pub struct WebSocketConnection { /* private fields */ }

WebSocket connection adapter bridging wire frames and EventSource/EventSink traits.

Implementations

impl WebSocketConnection

pub fn session(&self) -> &WebSocketSessionContext

pub async fn send(&self, event: WebSocketEvent) -> Result<(), WebSocketError>

pub async fn send_json<T>(&self, value: &T) -> Result<(), WebSocketError>

where T: Serialize,

pub async fn next_json<T>(&mut self) -> Result<Option<T>, WebSocketError>

where T: DeserializeOwned,

Trait Implementations

impl EventSink<String> for WebSocketConnection

type Error = WebSocketError

fn send_event<'life0, 'async_trait>( &'life0 self, event: String, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Sends an event to the sink.

impl EventSink<Vec<u8>> for WebSocketConnection

type Error = WebSocketError

fn send_event<'life0, 'async_trait>( &'life0 self, event: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Sends an event to the sink.

impl EventSink<WebSocketEvent> for WebSocketConnection

type Error = WebSocketError

fn send_event<'life0, 'async_trait>( &'life0 self, event: WebSocketEvent, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Sends an event to the sink.

impl EventSource<WebSocketEvent> for WebSocketConnection

fn next_event<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Option<WebSocketEvent>> + Send + 'async_trait>>

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

Returns the next event, or None if the source is exhausted/closed.