pub trait SubscriptionManager<T>: SubscriptionQuery<T> {
// Required methods
fn subscribe(&self, req: SubscribeRequest<T>) -> Result<()>;
fn unsubscribe(&self, req: UnsubscribeRequest) -> Result<()>;
fn unsubscribe_all(&self) -> Result<()>;
}