Provides functionality for async event handling using Manifold, including an in-memory implementation of a broker. This is similar to the one provided in the core lib and is mainly useful for testing/development purposes.
Provides functionality for async event handling using [Manifold](https://github.com/clj-commons/manifold), including an in-memory implementation of a broker. This is similar to the one provided in the core lib and is mainly useful for testing/development purposes.
(async-invoker handlers evt)Routing invoker that assumes the handlers return a deferred value. Invokes each
of them in parallel and returns a deferred that will hold the results, as per
manifold.deferred.zip.
Routing invoker that assumes the handlers return a deferred value. Invokes each of them in parallel and returns a deferred that will hold the results, as per `manifold.deferred.zip`.
(manifold-broker & {:keys [buf-size] :or {buf-size 10}})(start-broker broker)Starts receiving events from the broker stream and dispatching them to the listeners.
Starts receiving events from the broker stream and dispatching them to the listeners.
(stop-broker broker)Shuts down the broker stream
Shuts down the broker stream
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |