Struct SourceHandle 

pub struct SourceHandle<E: Encoding = FlatBuffers> { /* 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<E: Encoding> Attached for SourceHandle<E>

fn catalog(&self) -> &CatalogRef

The catalog this port serves.

impl<E: Encoding> Drop for SourceHandle<E>

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<E: Encoding> Encoded for SourceHandle<E>

type Encoding = E

The encoding of the bytes this port carries.

impl<E: Encoding> EventSource for SourceHandle<E>

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<E: Encoding> Wakeable for SourceHandle<E>

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.