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
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.
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?
- dropping-stream
- filter
- lazily-partition-by
- map
- mapcat
- on-closed
- on-drained
- onto
- periodically
- put!
- put-all!
- realize-each
- reduce
- reductions
- sink-only
- sink?
- sinkable?
- sliding-stream
- source-only
- source?
- sourceable?
- splice
- stream
- stream*
- stream->seq
- stream?
- synchronous?
- take!
- throttle
- transform
- try-put!
- try-take!
- weak-handle
- zip
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 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 |