arifa 0.3.48

Redis-based realtime pub/sub engine for WebSocket applications
Documentation 
1
2
3
4
5
6
7
8
9

use crate::models::WsMessage;
use async_trait::async_trait;

#[async_trait]
pub trait WsSession: Send + Sync + 'static {
    type Error: std::error::Error + Send + Sync + 'static;

    async fn send(&self, event: WsMessage) -> Result<(), Self::Error>;
}