pub trait ProcessMessages {
    fn process_messages(
        self: Arc<Self>,
        pnode: &mut AmoWriteGuard<'_, Box<dyn NodeInterface>>,
        interrupt: &AtomicBool
    ) -> bool; }

Required Methods§

| 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 |

Implementors§