diff --git a/blahd/src/event.rs b/blahd/src/event.rs index f178db8..0e99253 100644 --- a/blahd/src/event.rs +++ b/blahd/src/event.rs @@ -63,7 +63,7 @@ fn de_duration_sec<'de, D: de::Deserializer<'de>>(de: D) -> Result>, + pub user_listeners: Mutex>, } #[derive(Debug)] @@ -103,7 +103,7 @@ type UserEventSender = broadcast::Sender>; struct UserEventReceiver { rx: BroadcastStream>, st: Arc, - uid: u64, + uid: i64, } impl Drop for UserEventReceiver { @@ -147,8 +147,7 @@ pub async fn handle_ws(st: Arc, ws: &mut WebSocket) -> Result