From 83cbb0d7a7e5edfbe093c98242085e4eec3008c3 Mon Sep 17 00:00:00 2001
From: mcorbin <corbin.math@gmail.com>
Date: Tue, 25 May 2021 23:09:29 +0200
Subject: [PATCH] release 0.0.2-alpha6

---
 project.clj                    | 2 +-
 test/mirabelle/stream_test.clj | 7 +++++--
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/project.clj b/project.clj
index ec383c5..ef65fa6 100644
--- 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
index 834ec29..b772bc0 100644
--- 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"}]