Struct SourceHandle 

pub struct SourceHandle { /* private fields */ }

The EventSource port role: one subscription set and one queue, both in the store under this handle’s identity.

Each source handle receives its own copy of every occurrence raised while it is subscribed, so two consumers of one event never consume each other’s occurrences.

Trait Implementations

impl Attached for SourceHandle

fn catalog(&self) -> &CatalogRef

The catalog this port serves.

impl Drop for SourceHandle

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 EventSource for SourceHandle

fn subscribe( &mut self, iface: InterfaceNo, ords: &[Ordinal], ) -> Result<(), SubscribeError>

Starts delivery of the listed events.

fn unsubscribe(&mut self, iface: InterfaceNo, ords: &[Ordinal])

Stops delivery of the listed events.

fn next(&mut self, out: &mut [u8]) -> Result<Option<RawOccurrence>, ReadError>

Copies the next occurrence into the front of out. Ok(None) when no occurrence is waiting.