Struct WatchStream 

pub struct WatchStream { /* private fields */ }

A stream of WatchEvent values backed by a crossbeam channel.

Implements futures_core::Stream for async consumption. The stream yields Some(event) for each change and returns None when all senders are dropped (database closed or subscriber removed).

Dropping a WatchStream automatically unregisters the subscriber from the watch service, preventing memory leaks.

Trait Implementations

impl Debug for WatchStream

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

Formats the value using the given formatter.

impl Drop for WatchStream

fn drop(&mut self)

Executes the destructor for this type.

impl Stream for WatchStream

type Item = WatchEvent

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.