fn pending_message(&self, message_filter: &MessageFilter) -> Option<NetworkMsg<Block>> {
		if let Some(message) = self.buffered_message(message_filter) {
			return Some(message);
		}

		while let Some(message) = self.channel_message() {
			if message_filter(&message) {
				return Some(message)
			} else {
				self.buffered_messages.lock().push_back(message);
			}
		}

		None
	}
/// Produce the next pending message to send to another peer.
Produce the next pending message to send to another peer.
Produce the next pending message to send to another peer .
fn pending_message(&self, message_filter: &MessageFilter) -> Option<NetworkMsg<Block>> {
		if let Some(message) = self.buffered_message(message_filter) {
			return Some(message);
		}
		while let Some(message) = self.channel_message() {
			if message_filter(&message) {
				return Some(message)
			} else {
				self.buffered_messages.lock().push_back(message);
			}
		}
		None
	}
fn pending_message ( & self , message_filter : & MessageFilter ) -> Option < NetworkMsg < Block > > { if let Some ( message ) = self . buffered_message ( message_filter ) { return Some ( message ) ; } while let Some ( message ) = self . channel_message ( ) { if message_filter ( & message ) { return Some ( message ) } else { self . buffered_messages . lock ( ) . push_back ( message ) ; } } None }
Produce the next pending message to send to another peer.
Produce the next pending message to send to another peer .
&self
message_filter
&MessageFilter
&self
message_filter
&MessageFilter