This repository has been archived by the owner. It is now read-only.
Permalink
Browse files

Merge pull request #38 from fuziontech/perf

Fix distributor doc and example
  • Loading branch information...
2 parents 060f700 + 0f0681d commit c166698c1882dee1f5f3c023c3cc06ed5d0966ec @ztellman committed May 22, 2012
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/lamina/core/channel.clj
@@ -368,9 +368,9 @@
types:
(distributor :type
- (fn [ch facet]
+ (fn [facet ch]
(siphon
- (->> ch (map* :value) average)
+ (->> ch (map* :value) mean)
(sink #(println \"average for\" facet \"is\" %)))))"
[facet channel-initializer]
(let [receiver (g/node identity)

0 comments on commit c166698

Please sign in to comment.