This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
;; There are some patterns with c.a.flow that weren't immediately obvious to me so I made this gist to | |
;; figure them out. | |
;; Those patterns are: | |
;; - backpressure across processes | |
;; - long-running tasks | |
;; - getting inputs for the first process in the flow | |
(require '[clojure.core.async :as async] | |
'[clojure.core.async.flow :as flow] | |
'[clojure.pprint :as pp] |
OlderNewer