clojurewerkz.meltdown.reactor — clojurewerkz/meltdown 2.0.0-SNAPSHOT

Provides key reactor and message passing operations:

• Reactor instantiation
• Registration (subscription) for events
• Event notifications

create clj

(create &
        {:keys [dispatcher-type event-routing-strategy env dispatcher
                consumer-not-found-handler consumer-registry]})

Creates a reactor instance.

A new router is instantiated for every reactor, otherwise reactors will needlessly share state

dispatcher-types clj

maybe-wrap-event clj

(maybe-wrap-event ev)

Coerces given into to an Event instance

notify clj

(notify reactor payload)

(notify reactor key payload)

(notify reactor key payload completion-fn)

Broadcasts a event instantiated from provided payload (data structure)

notify-raw clj

(notify-raw reactor key payload)

on clj

(on reactor selector f)

Registers a Clojure function as event handler for a particular kind of events.

on-error clj

(on-error reactor exception-type f)

Registers a Clojure function as event handler for a class of Exception.

raw clj

receive-event clj

(receive-event reactor selector f)

Same as notify, except it checks for reply-to and sends a resulting callback. Used for optimization, since checking for reply-to is a (relatively) expensive operation

register-consumer clj

(register-consumer reactor selector consumer)

Registers a Clojure function as event handler for a particular kind of events.

responds-to? clj

(responds-to? reactor key)

Returns true if provded reactor has consumers registered for a particular key

send-event clj

(send-event reactor key event callback)