none of those mimics are necessary

dakrone · Sep 6, 2012 · 0b789a8 · 0b789a8
1 parent f09a3be
commit 0b789a8
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/lamina/core/channel.clj b/src/lamina/core/channel.clj
@@ -384,7 +384,7 @@
 (defn aggregate
   "something goes here"
   [facet ch]
-  (let [ch* (mimic ch)
+  (let [ch* (channel)
         lock (l/lock)
         aggregator (atom (ConcurrentHashMap.))]
     (bridge-join ch "aggregate"
@@ -412,7 +412,7 @@
 (defn distribute-aggregate
   "something goes here"
   [facet channel-initializer ch]
-  (let [ch* (mimic ch)
+  (let [ch* (channel)
         aggr (->> ch*
                (aggregate :facet))
         dist (distributor facet

diff --git a/src/lamina/core/operators.clj b/src/lamina/core/operators.clj
@@ -401,11 +401,11 @@
    from the source channel every 'period' milliseconds."
   [period ch]
   (let [val (atom ::none)
-        ch* (mimic ch)]
+        ch* (channel)]
     (bridge-join ch (str "sample-every " period)
       #(reset! val %)
       ch*)
-    (siphon
+    (join
       (->> #(deref val) (periodically period) (remove* #(= ::none %)))
       ch*)
     ch*))
@@ -420,7 +420,7 @@
                   (if (.isEmpty q)
                     msgs
                     (recur (conj msgs (.remove q))))))
-        ch* (mimic ch)]
+        ch* (channel)]
     (bridge-join ch (str "partition-every " period)
       #(.add q %)
       ch*)