manifold.bus
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.
manifold.deferred
Methods for creating, transforming, and interacting with asynchronous values.
Methods for creating, transforming, and interacting with asynchronous values.
manifold.go-off
Provide a variant of core.async/go that works with manifold's deferreds and executors. Utilizes core.async's state-machine generator, so core.async must be provided as a dependency.
Provide a variant of `core.async/go` that works with manifold's deferreds and executors. Utilizes core.async's state-machine generator, so core.async must be provided as a dependency.
manifold.stream
Methods for creating, transforming, and interacting with asynchronous streams of values.
Methods for creating, transforming, and interacting with asynchronous streams of values.
- ->sink
- ->source
- batch
- buffer
- buffered-stream
- close!
- closed?
- concat
- connect
- connect-via
- consume
- consume-async
- description
- downstream
- drain-into
- drained?
- filter
- lazily-partition-by
- map
- mapcat
- on-closed
- on-drained
- onto
- periodically
- put!
- put-all!
- realize-each
- reduce
- reductions
- sink-only
- sink?
- sinkable?
- source-only
- source?
- sourceable?
- splice
- stream
- stream*
- stream->seq
- stream?
- synchronous?
- take!
- throttle
- transform
- try-put!
- try-take!
- weak-handle
- zip
manifold.stream.async
No vars found in this namespace.
manifold.stream.deferred
No vars found in this namespace.
manifold.stream.iterator
No vars found in this namespace.
manifold.stream.queue
No vars found in this namespace.
manifold.stream.random-access
No vars found in this namespace.
manifold.stream.seq
No vars found in this namespace.
manifold.time
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