Source

clj-estuary /

Filename Size Date modified Message
src/estuary
test/estuary/test
559 B
119 B
545 B
516 B
1.6 KB
318 B

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.