clojure - How to make manifold stream with dropping buffer? -
using core.async i'm able create channel dropping buffer:
(async/chan (async/dropping-buffer 10)) is possible create manifold stream dropping buffer?
you can same result creating (s/stream 10), , using (try-put! msg 0) instead of put!, such puts full stream time out.
Comments
Post a Comment