pub fn join_bus(&self) -> BusConnector<T> {
        let mut senders = self.senders.lock().unwrap();

        let (sender, receiver) = unbounded();

        let id = senders.len().into();
        senders.push((id, sender));

        BusConnector::new(receiver, id, self.clone())
    }
/// Add another connection to the bus
Add another connection to the bus
Add another connection to the bus
pub fn join_bus(&self) -> BusConnector<T> {
        let mut senders = self.senders.lock().unwrap();
        let (sender, receiver) = unbounded();
        let id = senders.len().into();
        senders.push((id, sender));
        BusConnector::new(receiver, id, self.clone())
    }
pub fn join_bus ( & self ) -> BusConnector < T > { let mut senders = self . senders . lock ( ) . unwrap ( ) ; let ( sender , receiver ) = unbounded ( ) ; let id = senders . len ( ) . into ( ) ; senders . push ( ( id , sender ) ) ; BusConnector :: new ( receiver , id , self . clone ( ) ) }
Add another connection to the bus
Add another connection to the bus
&self
&self