Karsten Schmidt is sharing code with you

Bitbucket is a code hosting site. Unlimited public and private repositories. Free for small teams.

postspectacular / clj-estuary

Easy construction of dataflow graphs using standard Clojure agents

Clone this repository (size: 25.7 KB): HTTPS / SSH

hg clone https://bitbucket.org/postspectacular/clj-estuary

hg clone ssh://hg@bitbucket.org/postspectacular/clj-estuary

clj-estuary overview

Recent commits See more »

Author	Revision	Message	Date
Karsten Schmidt	`234b0ca0b18c`	adding suppport for optional :serialize field to nodes to filter node date when serializing graph (only specified fields are included in addition to required default fields: id, init, func and targets)	2011-10-16
Karsten Schmidt	`80c544eb1814`	updating trigger function to support node IDs and node collections	2011-10-13
Karsten Schmidt	`156fd492571d`	adding node-target-tree function	2011-10-13
Karsten Schmidt	`9db12332d63c`	updating .hgignore	2011-10-12
Karsten Schmidt	`dba9c5b80abd`	updating test cases, adding lein-eclipse dev dependency, adding eclipse project files	2011-10-12

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

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