[fix] wait() filter didn't buffer more than one events when using a P…

…romise
flomesh-io · Jun 5, 2024 · 221edef · 221edef
1 parent 9b0601d
commit 221edef
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/src/filters/wait.cpp b/src/filters/wait.cpp
@@ -85,16 +85,18 @@ void Wait::process(Event *evt) {
   if (m_fulfilled) {
     output(evt);
 
-  } else if (!m_promise_callback) {
-    pjs::Value ret;
-    if (!callback(m_condition, 0, nullptr, ret)) return;
-    if (ret.is_promise()) {
-      auto cb = PromiseCallback::make(this);
-      ret.as<pjs::Promise>()->then(nullptr, cb->resolved(), cb->rejected());
-      m_promise_callback = cb;
-    } else if (ret.to_boolean()) {
-      fulfill();
-      Filter::output(evt);
+  } else {
+    if (!m_promise_callback) {
+      pjs::Value ret;
+      if (!callback(m_condition, 0, nullptr, ret)) return;
+      if (ret.is_promise()) {
+        auto cb = PromiseCallback::make(this);
+        ret.as<pjs::Promise>()->then(nullptr, cb->resolved(), cb->rejected());
+        m_promise_callback = cb;
+      } else if (ret.to_boolean()) {
+        fulfill();
+        Filter::output(evt);
+      }
     }
 
     if (!m_fulfilled) {