pub fn send<M>(&self, msg: M) -> Request<A, M>
    where
        M: Message + Send + 'static,
        M::Result: Send,
        A: Handler<M>,
        A::Context: ToEnvelope<A, M>,
    {
        match self.tx.send(msg) {
            Ok(rx) => Request::new(Some(rx), None),
            Err(SendError::Full(msg)) => Request::new(None, Some((self.tx.clone(), msg))),
            Err(SendError::Closed(_)) => Request::new(None, None),
        }
    }
/// Sends an asynchronous message and waits for a response.
///
/// The communication channel to the actor is bounded. If the
/// returned `Future` object gets dropped, the message is
/// cancelled.
Sends an asynchronous message and waits for a response.
The communication channel to the actor is bounded. If the
returned `Future` object gets dropped, the message is
cancelled.
Sends an asynchronous message and waits for a response . The communication channel to the actor is bounded . If the returned ` Future ` object gets dropped the message is cancelled .
pub fn send<M>(&self, msg: M) -> Request<A, M>
    where
        M: Message + Send + 'static,
        M::Result: Send,
        A: Handler<M>,
        A::Context: ToEnvelope<A, M>,
    {
        match self.tx.send(msg) {
            Ok(rx) => Request::new(Some(rx), None),
            Err(SendError::Full(msg)) => Request::new(None, Some((self.tx.clone(), msg))),
            Err(SendError::Closed(_)) => Request::new(None, None),
        }
    }
pub fn send < M > ( & self , msg : M ) -> Request < A , M > where M : Message + Send + ' static , M :: Result : Send , A : Handler < M > , A :: Context : ToEnvelope < A , M > , { match self . tx . send ( msg ) { Ok ( rx ) => Request :: new ( Some ( rx ) , None ) , Err ( SendError :: Full ( msg ) ) => Request :: new ( None , Some ( ( self . tx . clone ( ) , msg ) ) ) , Err ( SendError :: Closed ( _ ) ) => Request :: new ( None , None ) , } }
Sends an asynchronous message and waits for a response.
Sends an asynchronous message and waits for a response .
&self
msg
M
&self
msg
M