release 0.0.2-alpha6

appclacks · May 25, 2021 · 83cbb0d · 83cbb0d
1 parent 485ec25
commit 83cbb0d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/project.clj b/project.clj
@@ -1,4 +1,4 @@
-(defproject fr.mcorbin/mirabelle "0.0.2-alpha5"
+(defproject fr.mcorbin/mirabelle "0.0.2-alpha6"
   :description "A stream processing engine inspired by Riemann"
   :url "https://github.com/mcorbin/mirabelle"
   :license {:name "EPL-2.0"

diff --git a/test/mirabelle/stream_test.clj b/test/mirabelle/stream_test.clj
@@ -649,6 +649,7 @@
 (deftest reaper-test
   (let [index (component/start (index/map->Index {}))
         recorder (atom [])
+        dest (atom [])
         pubsub (component/start (pubsub/map->PubSub {}))
         stream {:name "my-stream"
                 :description "foo"
@@ -657,8 +658,9 @@
         {:keys [entrypoint]} (stream/compile-stream!
                               {:index index
                                :pubsub pubsub
-                               :input :streaming
-                               :reinject (fn [event _]
+                               :input :default
+                               :reinject (fn [event destination-stream]
+                                           (swap! dest conj destination-stream)
                                            (swap! recorder conj event))}
                               stream)]
     (entrypoint {:host "f" :metric 12 :time 1 :ttl 15})
@@ -667,6 +669,7 @@
     (entrypoint {:host "b" :metric 12 :time 17})
     (is (= 17 (index/current-time index)))
     (is (= 1 (index/size-index index)))
+    (is (= [:default] @dest))
     (is (= [{:host "b" :metric 12 :time 17}]
            (index/search index [:always-true])))
     (is (= [{:host "f" :metric 12 :time 1 :ttl 15 :state "expired"}]