Struct EventStream 

pub struct EventStream { /* private fields */ }

Implementations

impl EventStream

pub fn new() -> Self

pub fn subscribe<T: Any + Send + Sync>( &self, f: impl Fn(&T) + Send + Sync + 'static, ) -> Subscription

pub fn subscribe_filtered<T, P>( &self, pred: P, f: impl Fn(&T) + Send + Sync + 'static, ) -> Subscription

where T: Any + Send + Sync, P: Fn(&T) -> bool + Send + Sync + 'static,

Subscribe with a predicate filter — only events matching pred(t) are delivered to f. Phase 3.5 of docs/full-port-plan.md. EventStream.Subscribe(IActorRef, predicate) analog.

pub fn subscriber_count<T: Any>(&self) -> usize

Number of subscribers registered for events of type T.

pub fn publish<T: Any + Send + Sync>(&self, value: T)

Trait Implementations

impl Default for EventStream

fn default() -> EventStream

Returns the “default value” for a type.