Struct 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