Struct overclock::core::Marker

pub struct Marker<T, B> { /* private fields */ }

Marker struct useful to propagate bounds through the Supervisor generic

Implementations

impl<T, B> Marker<T, B>

pub fn new(inner: T) -> Self

Create new marker wrapper

Trait Implementations

impl<T, B: Send + Sync + 'static> Channel for Marker<T, B>where T: Channel,

type Event = <T as Channel>::Event

The channel Event type

type Handle = Marker<<T as Channel>::Handle, B>

The sender half of the channel

type Inbox = <T as Channel>::Inbox

The receiver half of the channel

type Metric = <T as Channel>::Metric

Metric Collector

fn channel<A>( self, scope_id: ScopeId ) -> (Self::Handle, Self::Inbox, AbortRegistration, Option<T::Metric>, Option<Box<dyn Route<T::Event>>>)

Create a sender and receiver of the appropriate types

fn type_name() -> Cow<'static, str>

Get this channel’s name

impl<T, B> Clone for Marker<T, B>where T: Clone,

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, B> Deref for Marker<T, B>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T, B> DerefMut for Marker<T, B>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T: Shutdown + Clone, B: Send + Sync + 'static> Shutdown for Marker<T, B>

fn shutdown<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Send shutdown signal to the corresponding actor

fn scope_id(&self) -> ScopeId

Return the corresponding actor’s scope_id