wire.core — controlroom/wire 0.3.0

Wire is a simple abstraction allowing for message streaming

act clj/s

(act wire criteria)

(act wire criteria payload)

Send a payload up the wire with criteria.

BaseWire clj/s≠ protocol

-act clj/s

(-act this criteria payload)

-data clj/s

(-data this)

-lay clj/s

(-lay this key context)

-tap clj/s

(-tap this criteria f)

data clj/s

(data wire)

Get at the wire's data structure. It's a private thing.

find-tap-fns clj/s

(find-tap-fns act-criteria registered-taps)

Search through all registered wiretap fns and use set logic to find any criteria matches to execute

group-merge clj/s

(group-merge & maps)

Merge conflicts into vectors. ex: (group-merge {:a :b} {:a :c}) => {:a [:b :c]} (group-merge {:a [:n :b]} {:a :c}) => {:a [:n :b :c]}

lay clj/s

(lay wire criteria & data)

Allows you to inject both data and critera into your wire. The data can only be retrieved by an owner and only when a wire is acted upon. Attaching data allows for components to have state, yet behave anonymously from that state. The critera is merged with any act criteria down the wire

tap clj/s

(tap wire criteria f)

Attaches a wiretap listener to some criteria. When the wire is acted upon, it looks for matching criteria on collected wiretaps.

taps clj/s

(taps wire & taps)

Allow attachment of multiple taps at once. Can list keys/fns in pairs.

(wire/taps wire :key-1 (fn [o] (do-something o)) {:other :keys} (fn [o] (somethind-else o)))

wire clj/s

(wire)

(wire data)

Create a new wire

Wire cljs

wire-set clj/s

(wire-set m)

Allow for vectors of values to be used as criteria, we just transpose vector keys into another set of parings ex: {:a [:b :c]} => #{[:a :b] [:a :c]}