Trait bitcoin_peerman::ProcessMessage
source · pub trait ProcessMessage {
// Required method
fn process_message(
self: Arc<Self>,
pfrom: &mut AmoWriteGuard<'_, Box<dyn NodeInterface>>,
msg_type: &str,
recv: &mut DataStream,
time_received: &OffsetDateTime,
interrupt_msg_proc: &AtomicBool
);
}Required Methods§
sourcefn process_message(
self: Arc<Self>,
pfrom: &mut AmoWriteGuard<'_, Box<dyn NodeInterface>>,
msg_type: &str,
recv: &mut DataStream,
time_received: &OffsetDateTime,
interrupt_msg_proc: &AtomicBool
)
fn process_message( self: Arc<Self>, pfrom: &mut AmoWriteGuard<'_, Box<dyn NodeInterface>>, msg_type: &str, recv: &mut DataStream, time_received: &OffsetDateTime, interrupt_msg_proc: &AtomicBool )
| Process a single message from a peer. | Public for fuzz testing |