Struct Subscription 

pub struct Subscription(/* private fields */);

A live subscription handle returned by [GraphDb::subscribe_rule] etc.

Dropping this value unregisters the subscriber: the next commit will detect the dead Weak reference and prune the entry, so no resources leak.

Implementations

impl Subscription

pub fn try_recv(&self) -> Option<DbEvent>

Non-blocking read. Returns None if the queue is empty.

pub fn recv_timeout(&self, timeout: Duration) -> Option<DbEvent>

Blocking read with timeout. Returns None on timeout.

Use tokio::task::spawn_blocking to bridge into an async context.

Trait Implementations

impl Clone for Subscription

fn clone(&self) -> Subscription

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Subscription

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

Formats the value using the given formatter.