reach_websocket

Function on_upgrade

Source 
pub fn on_upgrade<const B: usize, E, D, C, W>(
    upgrade: WebSocketUpgrade<E, D, C>,
    session_context_init: impl FnOnce() -> Arc<RwLock<D::SessionContext>> + Clone + Send + 'static,
) -> Response
where
    D: RequestDelegator<C> + 'static,
    D::GlobalContext: Send + Sync + 'static,
    D::SessionContext: Send + Sync + 'static,
    C: CommunicableTypes + 'static,
    C::Req: Send + Sync,
    C::Resp: From<GenericWebSocketError> + Send + Sync,
    E: Clone + Send + 'static,
    W: WebSocketContext<Incoming = C::Req, Outgoing = C::Resp> + Send + Unpin + 'static,
    W::Responder: Send + Sync,
    W::Options: From<(WebSocketChannel<TokioIo<Upgraded>, C::Req, C::Resp>, E)> + IntoWebSocketContext<W, Channel = Sender<RawWebSocketItem<W::Incoming, W::Outgoing>>>,