Struct DaemonSubscription 

pub struct DaemonSubscription { /* private fields */ }

A live push subscription opened by DaemonClient::subscribe.

The daemon keeps sending DaemonReply frames on the connection; call next in a loop to consume them. It exposes reads only — the protocol treats any further write as a cancel — and dropping it (e.g. on Ctrl-C) ends the stream.

Implementations

impl DaemonSubscription

pub async fn next(&mut self) -> Option<Result<DaemonReply>>

Reads the next pushed reply, None once the daemon closes the stream (EOF), or Some(Err(..)) on a read/decode failure.

Trait Implementations

impl Debug for DaemonSubscription

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

Formats the value using the given formatter.