Struct overclock::core::UnboundedHandle
source · pub struct UnboundedHandle<T> { /* private fields */ }
Expand description
Unbounded handle
Implementations§
source§impl<T> UnboundedHandle<T>
impl<T> UnboundedHandle<T>
sourcepub fn new(
sender: UnboundedSender<T>,
gauge: IntGauge,
abort_handle: AbortHandle,
scope_id: ScopeId
) -> Self
pub fn new(
sender: UnboundedSender<T>,
gauge: IntGauge,
abort_handle: AbortHandle,
scope_id: ScopeId
) -> Self
Create new abortable handle
sourcepub fn send_after(
&self,
message: T,
duration: Duration
) -> JoinHandle<Result<(), SendError<T>>>where
T: Send + 'static,
pub fn send_after(
&self,
message: T,
duration: Duration
) -> JoinHandle<Result<(), SendError<T>>>where
T: Send + 'static,
Send message to the channel after the duration pass
sourcepub fn same_channel(&self, other: &Self) -> bool
pub fn same_channel(&self, other: &Self) -> bool
Returns true if senders belong to the same channel