per_oxo 0.1.1

A highly reactive chat_server
Documentation 
1
2
3
4
5
6
7
8
9
10

use crate::state::PerOxoState;
use axum::extract::ws::WebSocket;
use std::sync::Arc;

pub async fn dm_socket(socket: WebSocket, user_id: i32, state: Arc<PerOxoState>) {
    state
        .connection_manager
        .handle_connection(socket, user_id)
        .await;
}