on-realized
, which would cause (on-realized form a b)
to execute form
twicejava.util.Iterator
(take! (->source chan))
instead)BasicStream
and CompletableFuture
, which can be optionally disabledonto
method to manifold.stream
to mirror the one in manifold.deferred
batch
and throttle
when the source is a permanent streammanifold.stream/reduce
could fail to yield any value when the reducer function throws an exception, rather than yielding that errormock-clock
and with-clock
to manifold.time
, to aid with testing timeouts and other wall-clock behaviorconsume-async
method, which expects the consume callback to return a deferred that yields a boolean, rather than simply a boolean value:thread-factory
parameter in manifold.executor
.Thanks to Tsutomu Yano and Joshua Griffith
finally
and consume
Thanks to Vadim Platonov, Miikka Koskinen, Alex Engelberg, and Oleh Palianytsia
batch
reduce
compatible with Clojure's reduced
short-circuitingcatch
can match non-Throwable
errorsloop
alt
mechanism for choosing the first of many deferreds to be realizedThanks to Ted Cushman, Vadim Platonov
throttle
, partition-all
, and transform
let-flow
to wait on all deferred values, not just the ones used by the bodyThanks to Paweł Stroiński
Throwable
deferred errors when dereferencingCan you improve this documentation? These fine people already did:
Zach Tellman & ztellmanEdit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close