Avoid intermediate toList for blocking/into

daveray · daveray · commit 1ffe5fb9c858 · 2014-02-24T22:51:15.000-08:00
diff --git a/language-adaptors/rxjava-clojure/src/main/clojure/rx/lang/clojure/blocking.clj b/language-adaptors/rxjava-clojure/src/main/clojure/rx/lang/clojure/blocking.clj
@@ -99,7 +99,8 @@
     rx/into
   "
   [to from-observable]
-  (first (rx/into to from-observable)))
+  (with-ex-unwrap
+    (clojure.core/into to (o->seq from-observable))))
 
 (defn doseq*
   "*Blocks* and executes (f x) for each x emitted by xs

Original file line number	Diff line number	Diff line change
`@@ -99,7 +99,8 @@`
`99`	`99`	`rx/into`
`100`	`100`	`"`
`101`	`101`	`[to from-observable]`
`102`		`- (first (rx/into to from-observable)))`
	`102`	`+ (with-ex-unwrap`
	`103`	`+ (clojure.core/into to (o->seq from-observable))))`
`103`	`104`
`104`	`105`	`(defn doseq*`
`105`	`106`	`"Blocks and executes (f x) for each x emitted by xs`