pub fn handle_message<R: Rng>(
        &mut self,
        sender_id: &D::NodeId,
        message: Message<D::Message>,
        rng: &mut R,
    ) -> Result<CpStep<Self>, Error<D::Error>> {
        if self.is_removed {
            return Ok(Step::<D>::default());
        }
        match message {
            Message::EpochStarted(epoch) => Ok(self.handle_epoch_started(sender_id, epoch)),
            Message::Algo(msg) => self.handle_message_content(sender_id, msg, rng),
        }
    }
/// Handles a message received from `sender_id`.
///
/// This must be called with every message we receive from another node.
Handles a message received from `sender_id`.
This must be called with every message we receive from another node.
Handles a message received from ` sender_id ` . This must be called with every message we receive from another node .
pub fn handle_message<R: Rng>(
        &mut self,
        sender_id: &D::NodeId,
        message: Message<D::Message>,
        rng: &mut R,
    ) -> Result<CpStep<Self>, Error<D::Error>> {
        if self.is_removed {
            return Ok(Step::<D>::default());
        }
        match message {
            Message::EpochStarted(epoch) => Ok(self.handle_epoch_started(sender_id, epoch)),
            Message::Algo(msg) => self.handle_message_content(sender_id, msg, rng),
        }
    }
pub fn handle_message < R : Rng > ( & mut self , sender_id : & D :: NodeId , message : Message < D :: Message > , rng : & mut R , ) -> Result < CpStep < Self > , Error < D :: Error > > { if self . is_removed { return Ok ( Step :: < D > :: default ( ) ) ; } match message { Message :: EpochStarted ( epoch ) => Ok ( self . handle_epoch_started ( sender_id , epoch ) ) , Message :: Algo ( msg ) => self . handle_message_content ( sender_id , msg , rng ) , } }
Handles a message received from `sender_id`.
Handles a message received from ` sender_id ` .
&mut self
sender_id
&D::NodeId
message
Message<D::Message>
rng
&mut R
&mut self
sender_id
&D::NodeId
message
Message<D::Message>
rng
&mut R