pub struct ControlSender { /* private fields */ }Expand description
The sending half of a control channel — cloneable, cheap, Send + Sync. crate::pipeline::Pipeline holds one to reach its source;
crate::queue::Queue holds one internally to reach its worker
thread across the thread boundary it owns.
Implementations§
Source§impl ControlSender
impl ControlSender
Sourcepub fn send(&self, msg: ControlMsg)
pub fn send(&self, msg: ControlMsg)
Sends msg and blocks until the receiver — and, transitively,
everything downstream of it — has finished handling it. A no-op
(returns immediately) if nothing is on the other end to receive it
(e.g. the pipeline already finished).
Trait Implementations§
Source§impl Clone for ControlSender
impl Clone for ControlSender
Source§fn clone(&self) -> ControlSender
fn clone(&self) -> ControlSender
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 ControlSender
impl RefUnwindSafe for ControlSender
impl Send for ControlSender
impl Sync for ControlSender
impl Unpin for ControlSender
impl UnsafeUnpin for ControlSender
impl UnwindSafe for ControlSender
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