Struct EventClient 

pub struct EventClient<C: PackageConsumer> { /* private fields */ }

Reusable sans-I/O event subscriber.

Implementations

impl<C: PackageConsumer> EventClient<C>

pub fn new(config: Config) -> Result<Self, StartError>

Construct a bounded client.

pub fn active(&self) -> usize

Number of logical intents currently owned.

pub fn contains(&self, id: SubscriptionId) -> bool

Whether a subscription is still owned.

pub fn connection_selected( &mut self, id: SubscriptionId, generation: Option<u64>, )

Record the exact stream generation selected by the transport for the latest SUBSCRIBE.

pub fn start( &mut self, start: Start<C>, ) -> Result<Started<C::Value>, StartError>

Begin one subscription and return its ordered initial outputs.

pub fn response( &mut self, id: SubscriptionId, response: Option<&Response>, cnonce: &str, ) -> Vec<Output<C::Value>>

Consume one final SUBSCRIBE response. cnonce is fresh driver-supplied entropy for a possible digest retry.

pub fn notify( &mut self, transaction: u64, request: &Request, source: Peer, ) -> Vec<Output<C::Value>>

Consume and answer one NOTIFY. The driver token is returned unchanged in Output::RespondNotify.

pub fn consumer_drained(&mut self, id: SubscriptionId, count: usize)

Report application deliveries removed from the bounded queue.

pub fn timer_fired( &mut self, id: SubscriptionId, timer: Timer, generation: u64, ) -> Vec<Output<C::Value>>

Fire one exact timer generation.

pub fn unsubscribe(&mut self, id: SubscriptionId) -> Vec<Output<C::Value>>

Request an in-dialog Expires 0 operation.

pub fn shutdown(&mut self) -> Vec<Output<C::Value>>

Close admission and begin one bounded unsubscribe per live usage.

pub fn shutdown_deadline(&mut self) -> Vec<Output<C::Value>>

Force the global shutdown deadline and release all state.

Trait Implementations

impl<C: PackageConsumer> Debug for EventClient<C>

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

Formats the value using the given formatter.