A simple, flexible helper for building modular systems with clojure/core.async
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Failed to load latest commit information.



A simple, flexible helper for building modular systems with clojure/core.async

asystant aims to maximise decoupling of modules through an event-based architecture, using data dependencies rather than component dependencies to assemble the system. In addition, using core.async and a single, unifying interface decouples the overall system architecture from the execution model of individual modules.

You can also watch a talk given at Clojure eXchange 2015 which explains in more detail some motivation and how asystant works

###0.1.2 Changelog

  • ClojureScript support
  • Minor improvements to subsystem assembly


Clojars Project

Declare modules of the form:

{:ins #{topics} :outs #{topics} :pipe pipe-fn-creator}

Connect together your system design:

(asystant.core/add-modules asystant.core/new-system modules)

Build your system:

(asystant.build/build! system initialisation-params)

The pipe function creator takes a map of initialisation parameters and returns a pipe function.

(defn my-pipe-fn-creator [{:keys [bar]}]
  (fn [in-ch out-ch]
    (foo bar in-ch out-ch)))

A pipe function is a function that takes an input channel and an output channel. This will be called on each module when you call build! and should be used to connect your functionality to the rest of the system.

(defn my-pipe-fn [in-ch out-ch]
  (clojure.core.async/go-loop []
    (println (clojure.core.async/<! in-ch))

Pipe utilities are available for the most common uses (source, sink, transform), allowing most modules to avoid directly using core.async at all. The previous example could be rewritten:

(asystant.pipe/sink (fn [x] (println x)))

There is currently some basic system visualisation functionality (using loom and graphviz) which will be built on, allowing easy debugging of the system making it simple to identify problems


Copyright © 2015 Patrick Monteith

Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.