//! Pub-sub traits use super::*; use std::any::TypeId; use std::collections::HashMap; use std::sync::Arc; use tokio::sync::{ RwLock, mpsc, }; use message::Message; #[derive(Debug)] struct SubListInner { //TODO: how tf do we do this? //subs: RwLock>>>>>, } /// List of subscibers #[derive(Debug, Clone)] pub struct SubscriberListRef(Arc);