kinesin_rdt::common::messagingTrait MessageTarget
Source pub trait MessageTarget<MessageType, Target: MessageHandler<MessageType>> {
// Required methods
fn _messaging_defer(&self);
fn _messaging_get_target(&self) -> &Mutex<Target>;
fn _messaging_get_channel(
&self,
) -> (Sender<MessageType>, Receiver<MessageType>);
// Provided methods
fn _messaging_default_process_limit(&self) -> usize { ... }
fn inform(&self, message: MessageType) -> bool { ... }
fn process_messages(&self) -> bool { ... }
fn process_messages_limit(&self, limit: usize) -> bool { ... }
}