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))))