Skip to main content

dispatch_session_message

kvbm_engine::leader::session

Function dispatch_session_message 

Source 
pub async fn dispatch_session_message(
    sessions: &DashMap<SessionId, SessionMessageTx>,
    message: SessionMessage,
) -> Result<()>
Expand description

Route a unified SessionMessage to its session task.

All message variants are routed through a single DashMap<SessionId, SessionMessageTx> registry.