/// Pushes the given message onto the stream for the given destination
/// subnet.
Pushes the given message onto the stream for the given destination
subnet.
Pushes the given message onto the stream for the given destination subnet .
pub fn push(&mut self, destination: SubnetId, msg: RequestOrResponse) {
        if let RequestOrResponse::Response(response) = &msg {
            *self
                .responses_size_bytes
                .entry(response.respondent)
                .or_default() += msg.count_bytes();
        }
        self.streams.entry(destination).or_default().push(msg);
        debug_assert_eq!(
            Streams::calculate_stats(&self.streams),
            self.responses_size_bytes
        );
    }
pub fn push ( & mut self , destination : SubnetId , msg : RequestOrResponse ) { if let RequestOrResponse :: Response ( response ) = & msg { * self . responses_size_bytes . entry ( response . respondent ) . or_default ( ) += msg . count_bytes ( ) ; } self . streams . entry ( destination ) . or_default ( ) . push ( msg ) ; debug_assert_eq ! ( Streams calculate_stats ( self streams ) self responses_size_bytes ) ; }
Pushes the given message onto the stream for the given destination
subnet.
Pushes the given message onto the stream for the given destination subnet .
&mut self
destination
SubnetId
msg
RequestOrResponse