Struct LocalEventStream 

pub struct LocalEventStream { /* private fields */ }

Implementations

impl LocalEventStream

pub fn new(channel_capacity: usize) -> Self

pub fn reliable() -> Self

Trait Implementations

impl Drop for LocalEventStream

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl EventStream for LocalEventStream

fn publish<'a>( &'a self, subject: String, payload: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'a>>

fn subscribe<'a>( &'a self, subject: String, handler: Arc<dyn Handler>, ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'a>>