Skip to content
Browse files

Fixing bug on the run function

  • Loading branch information...
1 parent f4dfbeb commit 0e343713a01bf7caa591f067bfb90eb2cf24fbd0 @roman committed Feb 17, 2012
Showing with 1 addition and 4 deletions.
  1. +1 −4 src/river/core.clj
View
5 src/river/core.clj
@@ -146,10 +146,7 @@
(defn run
"Allows to terminate ask for termination of producer, filter or consumer."
[& more]
- (letfn [
- (redux [producer consumer] (producer consumer))
- ]
- (produce-eof (reduce redux more))))
+ (produce-eof (reduce #(%2 %1) (reverse more))))
(defmacro do-consumer [steps result]
"Binds the river-m monadic implementation to the domonad macro,

0 comments on commit 0e34371

Please sign in to comment.
Something went wrong with that request. Please try again.