Struct reth_tokio_util::EventSender

pub struct EventSender<T> { /* private fields */ }

A bounded broadcast channel for a task.

Implementations

impl<T: Clone + Send + Sync + 'static> EventSender<T>

pub fn new(events_channel_size: usize) -> Self

Creates a new EventSender.

pub fn notify(&self, event: T)

Broadcasts an event to all listeners.

pub fn new_listener(&self) -> EventStream<T>

Creates a new event stream with a subscriber to the sender as the receiver.

Trait Implementations

impl<T: Clone> Clone for EventSender<T>

fn clone(&self) -> EventSender<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for EventSender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for EventSender<T>

where T: Clone + Send + Sync + 'static,

fn default() -> Self

Returns the “default value” for a type.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 8 bytes