pub struct ReplicaInboxSender { /* private fields */ }Expand description
Sender end of a per-shard replica inbox. Send + Clone + Sync
(one std::sync::mpsc::Sender, no extra state) so the embedder can
hand it freely to runner threads.
Implementations§
Source§impl ReplicaInboxSender
impl ReplicaInboxSender
Sourcepub fn send(&self, ev: ReplicaApply) -> Result<(), SendError<ReplicaApply>>
pub fn send(&self, ev: ReplicaApply) -> Result<(), SendError<ReplicaApply>>
Send one event to the target shard. Fails only when the shard has dropped its receiver (the runtime stopped or the shard crashed) — the runner should treat that as “no more apply possible” and exit.
Trait Implementations§
Source§impl Clone for ReplicaInboxSender
impl Clone for ReplicaInboxSender
Source§fn clone(&self) -> ReplicaInboxSender
fn clone(&self) -> ReplicaInboxSender
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for ReplicaInboxSender
impl RefUnwindSafe for ReplicaInboxSender
impl Send for ReplicaInboxSender
impl Sync for ReplicaInboxSender
impl Unpin for ReplicaInboxSender
impl UnsafeUnpin for ReplicaInboxSender
impl UnwindSafe for ReplicaInboxSender
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