pub trait ProcessMessages {
// Required method
fn process_messages(
self: Arc<Self>,
pnode: &mut AmoWriteGuard<'_, Box<dyn NodeInterface>>,
interrupt: &AtomicBool
) -> bool;
}
Required Methods§
sourcefn process_messages(
self: Arc<Self>,
pnode: &mut AmoWriteGuard<'_, Box<dyn NodeInterface>>,
interrupt: &AtomicBool
) -> bool
fn process_messages( self: Arc<Self>, pnode: &mut AmoWriteGuard<'_, Box<dyn NodeInterface>>, interrupt: &AtomicBool ) -> bool
| Process protocol messages received | from a given node | | ———– | @param[in] pnode | | The node which we have received messages | from. | ––––– | @param[in] interrupt | | Interrupt condition for processing | threads | | ———– | @return | | True if there is more work to be done |