Method register

src/darkbird/router.rs:256–267

register new channel to router

(&self, sender: Sender<Msg>)

    /// register new channel to router
    pub async fn register(&self, sender: Sender<Msg>) -> Result<(), SessionResult> {
        let res = self.sender.send_timeout(Request::Register(sender), TIMEOUT).await;
        match res {
            Ok(_) => Ok(()),
            Err(e) => {
                match e {
                    SendTimeoutError::Timeout(_) => Err(SessionResult::Timeout),
                    SendTimeoutError::Closed(_) => Err(SessionResult::Closed),
                }
            }
        }
    }   


    /// dispatch msg by router