summaryrefslogtreecommitdiff
path: root/src/api/wait.rs
diff options
context:
space:
mode:
authorCan Celik <ogulcancelik@gmail.com>2026-08-23 02:01:24 +0300
committerGitHub <noreply@github.com>2026-08-23 02:01:24 +0300
commit20a500a7f3fa272326418312e3b57107ee96f0c4 (patch)
tree543fee1a1525714ddab70cc1bb07ccdd044359a4 /src/api/wait.rs
parentc9601b9396532a552679328c8f0804d52909bc84 (diff)
fix(api): start lifecycle subscriptions from live events (#3134)
refs #1270
Diffstat (limited to 'src/api/wait.rs')
-rw-r--r--src/api/wait.rs10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/api/wait.rs b/src/api/wait.rs
index 7da9b7a9..0c47fbff 100644
--- a/src/api/wait.rs
+++ b/src/api/wait.rs
@@ -674,8 +674,14 @@ pub(super) fn wait_for_event(
Ok(subscription) => subscription,
Err(response) => return Ok(Some(serde_json::to_string(&response).unwrap())),
};
- let mut active = match ActiveSubscription::new(subscription, &request_id, 0, api_tx, event_hub)
- {
+ let mut active = match ActiveSubscription::new(
+ subscription,
+ &request_id,
+ 0,
+ api_tx,
+ event_hub,
+ event_hub.current_sequence(),
+ ) {
Ok(active) => active,
Err(response) => return Ok(Some(serde_json::to_string(&response).unwrap())),
};