Struct CollectingHandler

pub struct CollectingHandler {
    pub messages: Vec<Message>,
}

Simple message handler that collects messages

Fields

messages: Vec<Message>

A vector of received messages.

Implementations

impl CollectingHandler

pub const fn new() -> Self

Create a new collecting handler

Trait Implementations

impl Default for CollectingHandler

fn default() -> Self

Returns the “default value” for a type.

impl MessageHandler for CollectingHandler

fn on_message<'life0, 'async_trait>( &'life0 mut self, message: Message, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

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

Handle a received message

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

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

Handle connection established

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

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

Handle connection closed

fn on_error<'life0, 'async_trait>( &'life0 mut self, error: WebSocketError, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

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

Handle errors

fn set_sender(&mut self, _sender: UnboundedSender<Message>)

Set the sender for outgoing messages (optional, default implementation does nothing)

fn send_message(&self, _message: Message) -> WebSocketResult<()>

Send a message through the WebSocket (optional, default implementation returns error)