kinesin_rdt::common::messaging

Trait 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 { ... }
}

Required Methods§

Source

fn _messaging_defer(&self)

Source

fn _messaging_get_target(&self) -> &Mutex<Target>

Source

fn _messaging_get_channel(&self) -> (Sender<MessageType>, Receiver<MessageType>)

Provided Methods§

Source

fn _messaging_default_process_limit(&self) -> usize

Source

fn inform(&self, message: MessageType) -> bool

Source

fn process_messages(&self) -> bool

Source

fn process_messages_limit(&self, limit: usize) -> bool

Implementors§