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())),
     };