/// Subsribes to messages from the bus
Subsribes to messages from the bus
Subsribes to messages from the bus
pub fn subscribe(&self) -> Receiver<T> {
        let (sender, reciever) = channel::<T>();
        let mut channels = self.channels.lock().unwrap();
        channels.push(sender);
        reciever
    }
pub fn subscribe ( & self ) -> Receiver < T > { let ( sender , reciever ) = channel :: < T > ( ) ; let mut channels = self . channels . lock ( ) . unwrap ( ) ; channels . push ( sender ) ; reciever }
Subsribes to messages from the bus
Subsribes to messages from the bus
&self