(defn
map<
"Deprecated - this function will be removed. Use transducer instead"
[f ch]
(reify
impl/Channel
(close! [_] (impl/close! ch))
(closed? [_] (impl/closed? ch))
impl/ReadPort
(take!
[_ fn1]
(let
[ret
(impl/take!
ch
(reify
impl/Handler
(active? [_] (impl/active? fn1))
(blockable? [_] true)
(commit
[_]
(let
[f1 (impl/commit fn1)]
(fn*
[p1__18545#]
(f1 (if (nil? p1__18545#) nil (f p1__18545#))))))))]
(if (and ret (not (nil? @ret))) (channels/box (f @ret)) ret)))
impl/WritePort
(put! [_ val fn1] (impl/put! ch val fn1))))