An implementation of an event bus, where publishers and subscribers can interact via topics.
An implementation of an event bus, where publishers and subscribers can interact via topics.
Methods for creating, transforming, and interacting with asynchronous values.
Methods for creating, transforming, and interacting with asynchronous values.
Provides a variant of core.async/go
that works with manifold's deferreds and streams. Utilizes core.async's state-machine generator, so core.async must be provided by consumers as a dependency.
Provides a variant of `core.async/go` that works with manifold's deferreds and streams. Utilizes core.async's state-machine generator, so core.async must be provided by consumers as a dependency.
Methods for creating, transforming, and interacting with asynchronous streams of values.
Methods for creating, transforming, and interacting with asynchronous streams of values.
This namespace contains methods for converting units of time, with milliseconds as the base representation, and for deferring execution of functions to some time in the future. In practice, the methods here are not necessary to use Manifold effectively - manifold.deferred/timeout
and manifold.stream/periodically
are more directly useful - but they are available for anyone who should need them.
This namespace contains methods for converting units of time, with milliseconds as the base representation, and for deferring execution of functions to some time in the future. In practice, the methods here are not necessary to use Manifold effectively - `manifold.deferred/timeout` and `manifold.stream/periodically` are more directly useful - but they are available for anyone who should need them.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close