Pre: Fix bad symbol.
This commit is contained in:
parent
b545ddc0e1
commit
04e772a5bc
1 changed files with 8 additions and 8 deletions
|
@ -24,14 +24,14 @@
|
|||
[datomish.util]])))
|
||||
|
||||
#?(:clj
|
||||
(defn pair-channel->lazy-seq
|
||||
"Returns a blocking lazy sequence of items taken from the provided channel."
|
||||
[channel]
|
||||
(lazy-seq
|
||||
(when-let [v (clojure.core.async/<!! channel)]
|
||||
(if (second v)
|
||||
(cons v nil)
|
||||
(cons v (channel->lazy-seq channel)))))))
|
||||
(defn pair-channel->lazy-seq
|
||||
"Returns a blocking lazy sequence of items taken from the provided channel."
|
||||
[channel]
|
||||
(lazy-seq
|
||||
(when-let [v (clojure.core.async/<!! channel)]
|
||||
(if (second v)
|
||||
(cons v nil)
|
||||
(cons v (pair-channel->lazy-seq channel)))))))
|
||||
|
||||
#?(:clj
|
||||
(defn run-to-pair-seq
|
||||
|
|
Loading…
Reference in a new issue