Struct StreamSubscription 

pub struct StreamSubscription { /* private fields */ }

A live Request::Subscribe stream yielding typed StreamFrames (snapshot, then events/lagged notices) until the daemon side closes. Holds the connection’s write half for its lifetime — a subscriber only reads, but dropping the writer would half-close the socket. Drop the subscription to disconnect (there is no request channel back).

Implementations

impl StreamSubscription

pub async fn next(&mut self) -> Result<Option<StreamFrame>, ClientError>

The next frame, or None when the daemon closed the stream. A frame this crate’s StreamFrame does not model (a NEWER daemon’s frame type) surfaces as ClientError::Malformed — a forward-compatible consumer reads raw frames via ControlClient::open_stream instead.

Trait Implementations

impl Debug for StreamSubscription

Hand-rolled like ControlClient’s: the boxed transport halves are not Debug.

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

Formats the value using the given formatter.