core.async.flow

A framework for building robust process flows with strict separation of application logic from topology, execution, communication, lifecycle, monitoring and error handling.

core.async.flow provides concrete implementations of processes (threads of activity) and flows (directed graphs of processes communicating via channels). You define pure data->data functions and a declarative flow topology, and the framework handles all channel I/O, thread lifecycle, error handling, and coordination.

Setup

deps.edn:

org.clojure/core.async {:mvn/version "1.7.733"}

Leiningen:

[org.clojure/core.async "1.7.733"]

See https://mvnrepository.com/artifact/org.clojure/core.async for the latest version.