tab_websocket/bus/
listener.rs1use crate::{
2 message::listener::WebsocketConnectionMessage,
3 resource::listener::{WebsocketAuthToken, WebsocketListenerResource},
4};
5use lifeline::{prelude::*, Resource};
6use tokio::sync::mpsc;
7
8lifeline_bus!(pub struct WebsocketListenerBus);
9
10impl Message<WebsocketListenerBus> for WebsocketConnectionMessage {
11 type Channel = mpsc::Sender<Self>;
12}
13
14impl Resource<WebsocketListenerBus> for WebsocketListenerResource {}
15impl Resource<WebsocketListenerBus> for WebsocketAuthToken {}