fn handle_incoming_reply(&mut self, pid: P, msg: R) {
        match self.demux.txs.get(&pid) {
            Some(tx) => {
                // Ignoring send errors here; it means the session has ended on our side,
                // but we'll realise this in the loop when trying to receive from it.
                let _ = tx.send(msg);
            }
            None => {
                // A message to a protocol we did not initiate.
                let _ = self
                    .errors
                    .tx
                    .send(SessionError::UnexpectedMessage(Box::new(msg)));
            }
        }
    }
/// Dispatch an incoming reply to the corresponding session that sent the orginal request as a client.
///
/// Abort if the protocol doesn't exist. This is an outgoing connection, the local party initiates.
Dispatch an incoming reply to the corresponding session that sent the orginal request as a client.
Abort if the protocol doesn't exist. This is an outgoing connection, the local party initiates.
Dispatch an incoming reply to the corresponding session that sent the orginal request as a client . Abort if the protocol doesn ' t exist . This is an outgoing connection the local party initiates .
fn handle_incoming_reply(&mut self, pid: P, msg: R) {
        match self.demux.txs.get(&pid) {
            Some(tx) => {
                // Ignoring send errors here; it means the session has ended on our side,
                // but we'll realise this in the loop when trying to receive from it.
                let _ = tx.send(msg);
            }
            None => {
                // A message to a protocol we did not initiate.
                let _ = self
                    .errors
                    .tx
                    .send(SessionError::UnexpectedMessage(Box::new(msg)));
            }
        }
    }
fn handle_incoming_reply ( & mut self , pid : P , msg : R ) { match self . demux . txs . get ( & pid ) { Some ( tx ) => { // Ignoring send errors here; it means the session has ended on our side, // but we'll realise this in the loop when trying to receive from it. let _ = tx . send ( msg ) ; } None => { // A message to a protocol we did not initiate. let _ = self . errors . tx . send ( SessionError :: UnexpectedMessage ( Box :: new ( msg ) ) ) ; } } }
Dispatch an incoming reply to the corresponding session that sent the orginal request as a client.
Dispatch an incoming reply to the corresponding session that sent the orginal request as a client .
&mut self
pid
P
msg
R