pub struct MessagePort<Intent, Effect> { /* private fields */ }
Expand description
Domain-specific wrapper around a MessageSender
Implementations§
Source§impl<Intent, Effect> MessagePort<Intent, Effect>
impl<Intent, Effect> MessagePort<Intent, Effect>
Sourcepub fn new(message_tx: MessageSender<Intent, Effect>) -> Self
pub fn new(message_tx: MessageSender<Intent, Effect>) -> Self
Create a new instance
Sourcepub fn into_inner(self) -> MessageSender<Intent, Effect>
pub fn into_inner(self) -> MessageSender<Intent, Effect>
Obtain the inner MessageSender
for the channel
Source§impl<Intent, Effect> MessagePort<Intent, Effect>
impl<Intent, Effect> MessagePort<Intent, Effect>
Sourcepub fn submit_message(&mut self, message: impl Into<Message<Intent, Effect>>)
pub fn submit_message(&mut self, message: impl Into<Message<Intent, Effect>>)
Enqueue a message into the channel
A utility function that detects and logs unexpected send failures that the submitter should not be bothered with.
Submitting a message is a fire-and-forget operation that must always succeed. The framework is responsible for dealing with unexpected failures.
Sourcepub fn submit_intent(&mut self, intent: impl Into<Intent>)
pub fn submit_intent(&mut self, intent: impl Into<Intent>)
Submit an intent
See also: Self::submit_message
Sourcepub fn submit_effect(&mut self, effect: impl Into<Effect>)
pub fn submit_effect(&mut self, effect: impl Into<Effect>)
Submit an effect
See also: Self::submit_message
Trait Implementations§
Source§impl<Intent, Effect> Clone for MessagePort<Intent, Effect>
impl<Intent, Effect> Clone for MessagePort<Intent, Effect>
Auto Trait Implementations§
impl<Intent, Effect> Freeze for MessagePort<Intent, Effect>
impl<Intent, Effect> !RefUnwindSafe for MessagePort<Intent, Effect>
impl<Intent, Effect> Send for MessagePort<Intent, Effect>
impl<Intent, Effect> Sync for MessagePort<Intent, Effect>
impl<Intent, Effect> Unpin for MessagePort<Intent, Effect>
impl<Intent, Effect> !UnwindSafe for MessagePort<Intent, Effect>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more