Manifold 0.1.9-alpha4
Released under the MIT License
a compatibility layer for event-driven abstractions.
Installation
To install, add the following dependency to your project or build file:
[manifold "0.1.9-alpha4"]
Namespaces
manifold.bus
An implementation of an event bus, where publishers and subscribers can interact via topics.
Public variables and functions:
manifold.deferred
Methods for creating, transforming, and interacting with asynchronous values.
Public variables and functions:
- ->deferred
- add-listener!
- alt
- alt'
- cancel-listener!
- catch
- catch'
- chain
- chain'
- claim!
- connect
- Deferrable
- deferrable?
- deferred
- deferred?
- error!
- error-deferred
- finally
- finally'
- future
- future-with
- let-flow
- let-flow'
- listener
- loop
- on-realized
- onto
- realized?
- recur
- success!
- success-deferred
- timeout!
- unwrap
- unwrap'
- zip
- zip'
manifold.executor
Public variables and functions:
- execute-pool
- executor
- executor-thread-local
- fixed-thread-executor
- instrumented-executor
- register-execute-pool-stats-callback
- register-wait-pool-stats-callback
- stats->map
- thread-factory
- unregister-execute-pool-stats-callback
- unregister-wait-pool-stats-callback
- utilization-executor
- wait-pool
- with-executor
manifold.stream
Methods for creating, transforming, and interacting with asynchronous streams of values.
Public variables and functions:
- ->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.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.
Public variables and functions: