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

The source’s waker is dropped after the lock is released: it may be the last reference to a task that owns another handle of this runtime, and that handle’s own Drop takes the lock.

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.

impl Wakeable for SourceHandle

Stores one Event waker, whatever interface it was registered under, woken by any raise that queues an occurrence for this source.

fn wake_on(&self, what: Interest, waker: &Waker)

Wakes waker when the thing what names may have changed, under the contract above.