Source

clj-estuary / README.md

Full commit

Estuary

Easy construction of dataflow graphs using standard Clojure agents.

Usage

(ns user
    (:use [estuary.core]))

(defgraph g)
(defnode g a `set-value {:value 0})
(defnode g b `set-value {:value 0})
(defaccu g c `set-and-accumulate 2)
(conn! a c :in0)
(conn! b c :in1)
(send-off a set-value 23)
(send-off b set-value 42)
(Thread/sleep 100)
(is (= 65 (:value @c))))

License

Copyright (C) 2011 Karsten Schmidt

Distributed under the Eclipse Public License, the same as Clojure.