diff options
| author | Can Celik <ogulcancelik@gmail.com> | 2026-08-23 02:01:24 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2026-08-23 02:01:24 +0300 |
| commit | 20a500a7f3fa272326418312e3b57107ee96f0c4 (patch) | |
| tree | 543fee1a1525714ddab70cc1bb07ccdd044359a4 /src/api/wait.rs | |
| parent | c9601b9396532a552679328c8f0804d52909bc84 (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.rs | 10 |
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())), }; |
