Browse Source

bus.rs: Don't emit the latest message to new subscriptions.

tokio-broadcast
Jeb Rosen 2 months ago
parent
commit
32fb4a48bd
1 changed files with 1 additions and 1 deletions
  1. +1
    -1
      src/bus.rs

+ 1
- 1
src/bus.rs View File

@@ -100,7 +100,7 @@ impl<M> Bus<M> {
let watch_rx = self.watch.1.clone();
let current = *watch_rx.get_ref();

Subscription { data, filter: Box::new(|_| true), last_read: None, last_known: current, watch_rx }
Subscription { data, filter: Box::new(|_| true), last_read: current, last_known: current, watch_rx }
}
}



Loading…
Cancel
Save