pub struct AbortHandle { /* private fields */ }
Expand description
AbortHandle used to abort Abortable
Implementations§
Source§impl AbortHandle
impl AbortHandle
Sourcepub fn new_pair() -> (Self, AbortRegistration)
pub fn new_pair() -> (Self, AbortRegistration)
Create new (abort_handle, abort_registration) pair Note: AbortRegistration: should be used in sync order only.
Trait Implementations§
Source§impl Clone for AbortHandle
impl Clone for AbortHandle
Source§fn clone(&self) -> AbortHandle
fn clone(&self) -> AbortHandle
Returns a copy of the value. Read more
1.0.0 · 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 AbortHandle
impl !RefUnwindSafe for AbortHandle
impl Send for AbortHandle
impl Sync for AbortHandle
impl Unpin for AbortHandle
impl !UnwindSafe for AbortHandle
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
Source§impl<E, T, const C: usize> ChannelBuilder<AbortableBoundedChannel<E, C>> for T
impl<E, T, const C: usize> ChannelBuilder<AbortableBoundedChannel<E, C>> for T
Source§fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<AbortableBoundedChannel<E, C>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<AbortableBoundedChannel<E, C>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Implement how to build the channel for the corresponding actor
Source§impl<E, T> ChannelBuilder<AbortableUnboundedChannel<E>> for T
impl<E, T> ChannelBuilder<AbortableUnboundedChannel<E>> for T
Source§fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<AbortableUnboundedChannel<E>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<AbortableUnboundedChannel<E>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Implement how to build the channel for the corresponding actor
Source§impl<E, T, const C: usize> ChannelBuilder<BoundedChannel<E, C>> for Twhere
E: ShutdownEvent + 'static,
T: Send,
impl<E, T, const C: usize> ChannelBuilder<BoundedChannel<E, C>> for Twhere
E: ShutdownEvent + 'static,
T: Send,
Source§fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<BoundedChannel<E, C>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<BoundedChannel<E, C>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Implement how to build the channel for the corresponding actor
Source§impl<T, const I: u64> ChannelBuilder<IntervalChannel<I>> for Twhere
T: Send,
impl<T, const I: u64> ChannelBuilder<IntervalChannel<I>> for Twhere
T: Send,
Source§fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<IntervalChannel<I>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<IntervalChannel<I>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Implement how to build the channel for the corresponding actor
Source§impl<T, C, B> ChannelBuilder<Marker<C, B>> for T
impl<T, C, B> ChannelBuilder<Marker<C, B>> for T
Source§fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Marker<C, B>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<Marker<C, B>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Implement how to build the channel for the corresponding actor
Source§impl<T> ChannelBuilder<NullChannel> for Twhere
T: Send,
impl<T> ChannelBuilder<NullChannel> for Twhere
T: Send,
Source§fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<NullChannel, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<NullChannel, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Implement how to build the channel for the corresponding actor
Source§impl<E, T> ChannelBuilder<UnboundedChannel<E>> for Twhere
E: ShutdownEvent + 'static,
T: Send,
impl<E, T> ChannelBuilder<UnboundedChannel<E>> for Twhere
E: ShutdownEvent + 'static,
T: Send,
Source§fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<UnboundedChannel<E>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
fn build_channel<'life0, 'async_trait>(
&'life0 mut self,
) -> Pin<Box<dyn Future<Output = Result<UnboundedChannel<E>, ActorError>> + Send + 'async_trait>>where
'life0: 'async_trait,
T: 'async_trait,
Implement how to build the channel for the corresponding actor