pub fn handle_protocol_message(&mut self, message: ProtocolMessage<T>) {
        let sender = message.sender().clone();
        match message {
            ProtocolMessage::Join(m) => self.handle_join(m),
            ProtocolMessage::ForwardJoin(m) => self.handle_forward_join(m),
            ProtocolMessage::Neighbor(m) => self.handle_neighbor(m),
            ProtocolMessage::Shuffle(m) => self.handle_shuffle(m),
            ProtocolMessage::ShuffleReply(m) => self.handle_shuffle_reply(m),
            ProtocolMessage::Disconnect(m) => {
                self.handle_disconnect(m);
                return;
            }
        }
        self.disconnect_unless_active_view_node(sender);
    }
/// Handles the given incoming message.
Handles the given incoming message.
Handles the given incoming message .
pub fn handle_protocol_message(&mut self, message: ProtocolMessage<T>) {
        let sender = message.sender().clone();
        match message {
            ProtocolMessage::Join(m) => self.handle_join(m),
            ProtocolMessage::ForwardJoin(m) => self.handle_forward_join(m),
            ProtocolMessage::Neighbor(m) => self.handle_neighbor(m),
            ProtocolMessage::Shuffle(m) => self.handle_shuffle(m),
            ProtocolMessage::ShuffleReply(m) => self.handle_shuffle_reply(m),
            ProtocolMessage::Disconnect(m) => {
                self.handle_disconnect(m);
                return;
            }
        }
        self.disconnect_unless_active_view_node(sender);
    }
pub fn handle_protocol_message ( & mut self , message : ProtocolMessage < T > ) { let sender = message . sender ( ) . clone ( ) ; match message { ProtocolMessage :: Join ( m ) => self . handle_join ( m ) , ProtocolMessage :: ForwardJoin ( m ) => self . handle_forward_join ( m ) , ProtocolMessage :: Neighbor ( m ) => self . handle_neighbor ( m ) , ProtocolMessage :: Shuffle ( m ) => self . handle_shuffle ( m ) , ProtocolMessage :: ShuffleReply ( m ) => self . handle_shuffle_reply ( m ) , ProtocolMessage :: Disconnect ( m ) => { self . handle_disconnect ( m ) ; return ; } } self . disconnect_unless_active_view_node ( sender ) ; }
Handles the given incoming message.
Handles the given incoming message .
&mut self
message
ProtocolMessage<T>
&mut self
message
ProtocolMessage<T>