Do you think there's any way around this issue? https://clojure.atlassian.net/browse/ASYNC-163
when i encountered a similar issue with manifold i ended up setting the concurrency to N-2
in a wrapper 😬
I was thinking of modelling a delay mechanism by passing
(fn [x o]
(let [t (timeout t)]
(go
(<! t)
(put! o x)
(close! o))))
to an async pipeline but this issue breaks it =\