Trait polkadot_overseer::SubsystemSender [−][src]
pub trait SubsystemSender<Message>: 'static + Send + Clone {
fn send_message<'life0, 'async_trait>(
&'life0 mut self,
msg: Message
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>
where
'life0: 'async_trait,
Self: 'async_trait;
fn send_messages<'life0, 'async_trait, T>(
&'life0 mut self,
msgs: T
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>>
where
'life0: 'async_trait,
T: IntoIterator<Item = Message> + Send + 'async_trait,
Self: 'async_trait,
<T as IntoIterator>::IntoIter: Send;
fn send_unbounded_message(&mut self, msg: Message);
}
Expand description
Sender end of a channel to interface with a subsystem.
Required methods
Send a direct message to some other Subsystem
, routed based on message type.
fn send_messages<'life0, 'async_trait, T>(
&'life0 mut self,
msgs: T
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
T: IntoIterator<Item = Message> + Send + 'async_trait,
Self: 'async_trait,
<T as IntoIterator>::IntoIter: Send,
fn send_messages<'life0, 'async_trait, T>(
&'life0 mut self,
msgs: T
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
T: IntoIterator<Item = Message> + Send + 'async_trait,
Self: 'async_trait,
<T as IntoIterator>::IntoIter: Send,
Send multiple direct messages to other Subsystem
s, routed based on message type.
fn send_unbounded_message(&mut self, msg: Message)
fn send_unbounded_message(&mut self, msg: Message)
Send a message onto the unbounded queue of some other Subsystem
, routed based on message
type.
This function should be used only when there is some other bounding factor on the messages sent with it. Otherwise, it risks a memory leak.
Implementors
implementation for wrapping message type…