Struct WatchDispatcher 

pub struct WatchDispatcher { /* private fields */ }

Watch dispatcher - distributes events to watchers (background task)

This is spawned explicitly in NodeBuilder::build() to make resource allocation visible. It continuously:

1. Receives events from broadcast channel
2. Matches keys in the registry
3. Dispatches to matching watchers

Implementations

impl WatchDispatcher

pub fn new( registry: Arc<WatchRegistry>, broadcast_rx: Receiver<WatchEvent>, unregister_rx: UnboundedReceiver<(u64, Bytes)>, ) -> Self

Create a new watch dispatcher

Arguments

• registry - Shared registry for looking up watchers
• broadcast_rx - Receiver for watch events from StateMachine
• unregister_rx - Receiver for unregister requests from WatcherHandles

pub async fn run(self)

Run the dispatcher event loop

This should be spawned as a tokio task in NodeBuilder::build(). It will run until the broadcast channel is closed.