diff options
| author | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-05-26 21:52:19 +0300 |
|---|---|---|
| committer | Ogulcan Celik <ogulcancelik@gmail.com> | 2026-05-26 21:53:50 +0300 |
| commit | 427c2606d8f62558e3949d2f44173175e96bed49 (patch) | |
| tree | 0d351c30c3132037beb75ea20c378d75e6b34c80 /src/api/event_hub.rs | |
| parent | 31e973502af205666cb4a48e3f9e10328f65cd4e (diff) | |
fix: deliver agent status subscriptions from event hub
Diffstat (limited to 'src/api/event_hub.rs')
| -rw-r--r-- | src/api/event_hub.rs | 7 |
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 + } } |
