(defn
filter>
"Deprecated - this function will be removed. Use transducer instead"
[p ch]
(reify
impl/Channel
(close! [_] (impl/close! ch))
(closed? [_] (impl/closed? ch))
impl/ReadPort
(take! [_ fn1] (impl/take! ch fn1))
impl/WritePort
(put!
[_ val fn1]
(if
(p val)
(impl/put! ch val fn1)
(channels/box (not (impl/closed? ch)))))))