Provides key reactor and message passing operations:
Provides key reactor and message passing operations: * Reactor instantiation * Registration (subscription) for events * Event notifications
(create & {:keys [dispatcher-type event-routing-strategy env dispatcher]})
Creates a reactor instance.
A new router is instantiated for every reactor, otherwise reactors will needlessly share state
Creates a reactor instance. A new router is instantiated for every reactor, otherwise reactors will needlessly share state
(maybe-wrap-event ev)
Coerces given into to an Event instance
Coerces given into to an Event instance
(notify reactor payload)
(notify reactor key payload)
(notify reactor key payload completion-fn)
Broadcasts a event instantiated from provided payload (data structure)
Broadcasts a event instantiated from provided payload (data structure)
(on reactor selector f)
Registers a Clojure function as event handler for a particular kind of events.
Registers a Clojure function as event handler for a particular kind of events.
(on-error reactor exception-type f)
Registers a Clojure function as event handler for a class of Exception.
Registers a Clojure function as event handler for a class of Exception.
(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
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 reactor consumer)
(register-consumer reactor selector consumer)
Registers a Clojure function as event handler for a particular kind of events.
Registers a Clojure function as event handler for a particular kind of events.
(responds-to? reactor key)
Returns true if provded reactor has consumers registered for a particular key
Returns true if provded reactor has consumers registered for a particular key
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close