Skip to content

Instantly share code, notes, and snippets.

@SerhiiKozachenko

SerhiiKozachenko/async_&_transducers.clj

Forked from lnostdal/async_&_transducers.clj
Created July 14, 2024 09:03
Show Gist options
  • Save SerhiiKozachenko/8d52cd6aaabacd232d63ead4d6eaec50 to your computer and use it in GitHub Desktop.
Save SerhiiKozachenko/8d52cd6aaabacd232d63ead4d6eaec50 to your computer and use it in GitHub Desktop.
Download ZIP
how to use transducer with clojure.core.async
Raw
async_&_transducers.clj
;; I keep forgetting how to do this stuff for some reason, so here goes:
(let [c (async/chan 1 (map #(* % 2)))]
(async/go
(loop []
(when-let [e (async/<! c)]
(println "async/go, e:" e)
(recur))))
(async/>!! c 1)
(async/>!! c 2))
async/go, e: 2
async/go, e: 4
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment