Skip to content

Commit d19bc42

Browse files
committed
seq->o should seq-ify arg
1 parent 7919c04 commit d19bc42

File tree

2 files changed

+3
-2
lines changed
  • language-adaptors/rxjava-clojure/src

2 files changed

+3
-2
lines changed

language-adaptors/rxjava-clojure/src/main/clojure/rx/lang/clojure/core.clj

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -285,8 +285,8 @@
285285
(defn ^Observable seq->o
286286
"Make an observable out of some seq-able thing. The rx equivalent of clojure.core/seq."
287287
[xs]
288-
(if xs
289-
(Observable/from ^Iterable xs)
288+
(if-let [s (clojure.core/seq xs)]
289+
(Observable/from ^Iterable s)
290290
(empty)))
291291

292292
;################################################################################

language-adaptors/rxjava-clojure/src/test/clojure/rx/lang/clojure/core_test.clj

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,6 +166,7 @@
166166
(deftest test-seq->o
167167
(is (= [] (b/into [] (rx/seq->o []))))
168168
(is (= [] (b/into [] (rx/seq->o nil))))
169+
(is (= [\a \b \c] (b/into [] (rx/seq->o "abc"))))
169170
(is (= [0 1 2 3] (b/first (rx/into [] (rx/seq->o (range 4))))))
170171
(is (= #{0 1 2 3} (b/first (rx/into #{} (rx/seq->o (range 4))))))
171172
(is (= {:a 1 :b 2 :c 3} (b/first (rx/into {} (rx/seq->o [[:a 1] [:b 2] [:c 3]]))))))

0 commit comments

Comments
 (0)