Manifold 0.1.3-alpha2
a compatibility layer for event-driven abstractions
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!
- 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.stream
Methods for creating, transforming, and interacting with asynchronous streams of values.
Public variables and functions:
- ->BufferedStream
- ->sink
- ->source
- batch
- buffer
- buffered-stream
- close!
- closed?
- concat
- connect
- connect-via
- consume
- consume-async
- description
- downstream
- 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: