clojurewerkz.meltdown.stream-graph — clojurewerkz/meltdown 1.1.0

accept clj

attach clj macro

(attach detached)

Attaches parts back to the graph as if they were declared as a part of the graph from the beginning.

batch* clj macro

(batch* f)

(batch* f & downstreams)

consume clj macro

(consume f)

create clj

detach clj macro

(detach body)

Detaches given functions from the graph, to be attached later on. Mostly used to break down functions into smaller pieces.

filter* clj macro

(filter* f)

(filter* f & downstreams)

Like clojure.core/filter but for graph computations

fmap* clj macro

(fmap* f)

(fmap* f & downstreams)

Like clojure.core/fmap but for graph computations

fold* clj macro

(fold* f)

(fold* f & downstreams)

Like clojure.core/fold but for graph computations

graph clj macro

(graph channel)

(graph channel & downstreams)

Creates a stream processing graph

map* clj macro

(map* f)

(map* f & downstreams)

Like clojure.core/map but for graph computations

mappend* clj macro

(mappend* monoid)

(mappend* monoid condition)

(mappend* monoid condition & downstreams)

Like clojure.core/mappend but for graph computations

reduce* clj macro

(reduce* f default-value)

(reduce* f default-value & downstreams)

Like clojure.core/reduce but for graph computations