aboutsummaryrefslogtreecommitdiff
path: root/src/api/event_hub.rs
diff options
context:
space:
mode:
authorOgulcan Celik <ogulcancelik@gmail.com>2026-05-26 21:52:19 +0300
committerOgulcan Celik <ogulcancelik@gmail.com>2026-05-26 21:53:50 +0300
commit427c2606d8f62558e3949d2f44173175e96bed49 (patch)
tree0d351c30c3132037beb75ea20c378d75e6b34c80 /src/api/event_hub.rs
parent31e973502af205666cb4a48e3f9e10328f65cd4e (diff)
fix: deliver agent status subscriptions from event hub
Diffstat (limited to 'src/api/event_hub.rs')
-rw-r--r--src/api/event_hub.rs7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/api/event_hub.rs b/src/api/event_hub.rs
index b66a2157..42cf47a2 100644
--- a/src/api/event_hub.rs
+++ b/src/api/event_hub.rs
@@ -36,4 +36,11 @@ impl EventHub {
.cloned()
.collect()
}
+
+ pub fn current_sequence(&self) -> u64 {
+ let Ok(state) = self.inner.lock() else {
+ return 0;
+ };
+ state.next_sequence
+ }
}