Struct OptimizedMessageHandler 

pub struct OptimizedMessageHandler<F> { /* private fields */ }

Available on crate feature websocket only.

Optimized handler that processes individual messages with automatic loop.

This handler type automatically manages the message receive loop and calls your function for each incoming message until the connection closes.

Example

use ignitia::prelude::*;

let handler = websocket_message_handler(|ws: WebSocketConnection, msg: Message| async move {
    match msg {
        Message::Text(text) => {
            ws.send_text(format!("Received: {}", text)).await.ok();
            Response::ok()
        }
        Message::Binary(data) => {
            ws.send_binary(data).await.ok();
            Response::ok()
        }
        _ => Response::ok()
    }
});

router.websocket("/ws/messages", handler);

Implementations

impl<F> OptimizedMessageHandler<F>

pub fn new(handler: F) -> Self

Create a new message handler from a function.

Trait Implementations

impl<F> Clone for OptimizedMessageHandler<F>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<F, Fut, R> UniversalWebSocketHandler<()> for OptimizedMessageHandler<F>

where F: Fn(WebSocketConnection, Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = R> + Send + 'static, R: IntoResponse,

fn call<'life0, 'async_trait>( &'life0 self, _req: Request, websocket: WebSocketConnection, ) -> Pin<Box<dyn Future<Output = Response> + Send + 'async_trait>>

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

Call the handler with request and WebSocket connection.