Struct WatcherSink 

pub struct WatcherSink<U> { /* private fields */ }

Persistent push target for watch updates.

The channel logic holds one WatcherSink per registered watcher and calls Self::push to deliver a structured update value. A failed push (e.g. EPIPE on a gone socket) tells the channel logic the watcher is dead; the corresponding TransportEvent::WatcherClosed / WatcherDied still flows back through the ingestion path for cleanup.

Implementations

impl<U> WatcherSink<U>

pub fn new( push: impl FnMut(&U) -> Result<(), CoreError> + Send + 'static, ) -> Self

Wrap a push closure as a watcher sink.

pub fn push(&mut self, update: &U) -> Result<(), CoreError>

Deliver one update value to the subscriber.

Errors

Returns the backend’s delivery error (e.g. the peer went away); the caller should evict the watcher and stop pushing.

Trait Implementations

impl<U> Debug for WatcherSink<U>

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

Formats the value using the given formatter.