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§

source

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 |

Implementors§