Struct Toolbox

pub struct Toolbox {
    pub send_msg: RwLock<Arc<dyn Fn(ConnectionId, WsResponseValue) -> bool + Send + Sync>>,
}

Fields

send_msg: RwLock<Arc<dyn Fn(ConnectionId, WsResponseValue) -> bool + Send + Sync>>

Implementations

impl Toolbox

pub fn new() -> Arc<Self>

pub fn set_ws_states( &self, states: Arc<DashMap<ConnectionId, Arc<WsStreamState>>>, oneshot: bool, )

pub fn send_ws_msg( sender: &Sender<Message>, resp: WsResponseValue, oneshot: bool, )

pub fn send(&self, conn_id: ConnectionId, resp: WsResponseValue) -> bool

pub fn send_response(&self, ctx: &RequestContext, resp: impl Serialize)

pub fn send_internal_error( &self, ctx: &RequestContext, code: ErrorCode, err: Error, )

pub fn send_request_error( &self, ctx: &RequestContext, code: ErrorCode, err: impl Into<Value>, )

pub fn send_log( &self, ctx: &RequestContext, level: LogLevel, msg: impl Into<String>, )

pub fn encode_ws_response<Resp: Serialize>( ctx: RequestContext, resp: Result<Resp>, ) -> Option<WsResponseValue>