pub async fn send_rpc(
        &mut self,
        recipient: PeerId,
        message: ConsensusMsg<T>,
        timeout: Duration,
    ) -> Result<ConsensusMsg<T>, RpcError> {
        let protocol = ProtocolId::ConsensusRpc;
        self.network_sender
            .send_rpc(recipient, protocol, message, timeout)
            .await
    }
/// Send a RPC to the destination peer using the `CONSENSUS_RPC_PROTOCOL` ProtocolId.
Send a RPC to the destination peer using the `CONSENSUS_RPC_PROTOCOL` ProtocolId.
Send a RPC to the destination peer using the ` CONSENSUS_RPC_PROTOCOL ` ProtocolId .
pub async fn send_rpc(
        &mut self,
        recipient: PeerId,
        message: ConsensusMsg<T>,
        timeout: Duration,
    ) -> Result<ConsensusMsg<T>, RpcError> {
        let protocol = ProtocolId::ConsensusRpc;
        self.network_sender
            .send_rpc(recipient, protocol, message, timeout)
            .await
    }
pub async fn send_rpc ( & mut self , recipient : PeerId , message : ConsensusMsg < T > , timeout : Duration , ) -> Result < ConsensusMsg < T > , RpcError > { let protocol = ProtocolId :: ConsensusRpc ; self . network_sender . send_rpc ( recipient , protocol , message , timeout ) . await }
Send a RPC to the destination peer using the `CONSENSUS_RPC_PROTOCOL` ProtocolId.
Send a RPC to the destination peer using the ` CONSENSUS_RPC_PROTOCOL ` ProtocolId .
&mut self
recipient
PeerId
message
ConsensusMsg<T>
timeout
Duration
&mut self
recipient
PeerId
message
ConsensusMsg<T>
timeout
Duration