Struct overclock::core::UnboundedChannel

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

A tokio unbounded mpsc channel implementation

Implementations

impl<E> UnboundedChannel<E>

pub fn new() -> Self

Create new unbounded channel

Trait Implementations

impl<E: ShutdownEvent + 'static> Channel for UnboundedChannel<E>

type Event = E

The channel Event type

type Handle = UnboundedHandle<E>

The sender half of the channel

type Inbox = UnboundedInbox<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<Self::Metric>, Option<Box<dyn Route<Self::Event>>>)

Create a sender and receiver of the appropriate types

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

Get this channel’s name

impl<E: ShutdownEvent + 'static, T> ChannelBuilder<UnboundedChannel<E>> for Twhere
    T: Send,

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

Implement how to build the channel for the corresponding actor