core-async

Ben Sless 2021-01-13T09:35:36.344100Z

Do you think there's any way around this issue? https://clojure.atlassian.net/browse/ASYNC-163

mccraigmccraig 2021-01-13T09:43:37.345300Z

when i encountered a similar issue with manifold i ended up setting the concurrency to N-2 in a wrapper 😬

Ben Sless 2021-01-13T10:25:21.346600Z

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 =\