Struct overclock::core::AbortableUnboundedChannel

pub struct AbortableUnboundedChannel<E> { /* private fields */ }

Abortable tokio unbounded mpsc channel implementation

Implementations

impl<E> AbortableUnboundedChannel<E>

pub fn new() -> Self

Create abortable unbounded channel

Trait Implementations

impl<E: Send + 'static> Channel for AbortableUnboundedChannel<E>

type Event = E

The channel Event type

type Handle = AbortableUnboundedHandle<E>

The sender half of the channel

type Inbox = AbortableUnboundedInbox<E>

The receiver half of the channel

type Metric = GenericGauge<AtomicI64>

Metric Collector

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

Create a sender and receiver of the appropriate types

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

Get this channel’s name

impl<E: Send + 'static, T> ChannelBuilder<AbortableUnboundedChannel<E>> for T where
    T: Send, 

fn build_channel<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = ActorResult<AbortableUnboundedChannel<E>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Implement how to build the channel for the corresponding actor