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

Required Methods§

source

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 |

Implementors§