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 is a website building & hosting documentation for Clojure/Script libraries
× close