From 80e17f8cfc6de098a7f4ff6fca958cc25843858e Mon Sep 17 00:00:00 2001
From: "alonso.torres" <alonso.torres@kaleidos.net>
Date: Wed, 3 Jul 2024 15:22:42 +0200
Subject: [PATCH] :sparkles: Add new signature for the run-store test helper

---
 .../test/frontend_tests/helpers/state.cljs    | 34 +++++++++++--------
 1 file changed, 19 insertions(+), 15 deletions(-)

diff --git a/frontend/test/frontend_tests/helpers/state.cljs b/frontend/test/frontend_tests/helpers/state.cljs
index 6c3c7cb2c7..37d245df5c 100644
--- a/frontend/test/frontend_tests/helpers/state.cljs
+++ b/frontend/test/frontend_tests/helpers/state.cljs
@@ -39,21 +39,25 @@
     store))
 
 (defn run-store
-  [store done events completed-cb]
-  (let [stream (ptk/input-stream store)]
-    (->> stream
-         (rx/take-until (rx/filter #(= :the/end %) stream))
-         (rx/last)
-         (rx/tap (fn []
-                   (completed-cb @store)))
-         (rx/subs! (fn [_] (done))
-                   (fn [cause]
-                     (js/console.log "[error]:" cause))
-                   (fn [_]
-                     (js/console.log "[complete]"))))
-    (doall (for [event events]
-             (ptk/emit! store event)))
-    (ptk/emit! store :the/end)))
+  ([store done events completed-cb]
+   (run-store store done events completed-cb nil))
+  ([store done events completed-cb stopper]
+   (let [stream (ptk/input-stream store)]
+     (->> stream
+          (rx/take-until (if stopper
+                           (stopper stream)
+                           (rx/filter #(= :the/end %) stream)))
+          (rx/last)
+          (rx/tap (fn []
+                    (completed-cb @store)))
+          (rx/subs! (fn [_] (done))
+                    (fn [cause]
+                      (js/console.log "[error]:" cause))
+                    (fn [_]
+                      (js/console.log "[complete]"))))
+     (doall (for [event events]
+              (ptk/emit! store event)))
+     (ptk/emit! store :the/end))))
 
 (defn get-file-from-store
   [store]