1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
use crate::{ message::connection::{WebsocketRecv, WebsocketSend}, resource::{connection::WebsocketResource, listener::WebsocketAuthToken}, }; use lifeline::{prelude::*, Resource}; use tokio::sync::mpsc; lifeline_bus!(pub struct WebsocketConnectionBus); impl Message<WebsocketConnectionBus> for WebsocketRecv { type Channel = mpsc::Sender<Self>; } impl Message<WebsocketConnectionBus> for WebsocketSend { type Channel = mpsc::Sender<Self>; } impl Resource<WebsocketConnectionBus> for WebsocketResource {} impl Resource<WebsocketConnectionBus> for WebsocketAuthToken {}