Indenting.
This commit is contained in:
parent
4262b10f55
commit
f4b9b867a4
1 changed files with 8 additions and 8 deletions
|
@ -25,14 +25,14 @@
|
||||||
[cljs.core.async :refer [<!]]])))
|
[cljs.core.async :refer [<!]]])))
|
||||||
|
|
||||||
#?(:clj
|
#?(:clj
|
||||||
(defn pair-channel->lazy-seq
|
(defn pair-channel->lazy-seq
|
||||||
"Returns a blocking lazy sequence of items taken from the provided channel."
|
"Returns a blocking lazy sequence of items taken from the provided channel."
|
||||||
[channel]
|
[channel]
|
||||||
(lazy-seq
|
(lazy-seq
|
||||||
(when-let [v (clojure.core.async/<!! channel)]
|
(when-let [v (clojure.core.async/<!! channel)]
|
||||||
(if (second v)
|
(if (second v)
|
||||||
(cons v nil)
|
(cons v nil)
|
||||||
(cons v (pair-channel->lazy-seq channel)))))))
|
(cons v (pair-channel->lazy-seq channel)))))))
|
||||||
|
|
||||||
#?(:clj
|
#?(:clj
|
||||||
(defn run-to-pair-seq
|
(defn run-to-pair-seq
|
||||||
|
|
Loading…
Reference in a new issue