Contributions by Erik Assum, Matthew Davidson, led, Dominic Monroe, Justin Sonntag
jammin
time/in
to return a deferredContributions by Reynald Borer, Alexey Kachayev, Pierre-Yves Ritschard, Ryan Smith, Zach Tellman, Luo Tian, and Philip van Heerden
time/in
cancellablelet-flow
body from executing on last deferred threadtimeout
future execution if deferred completes before timeoutlet-flow
in loop
Thanks to Paweł Stroiński
Throwable
deferred errors when dereferencingThanks 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 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 Tsutomu Yano and Joshua Griffith
finally
and consume
:thread-factory
parameter in manifold.executor
.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 valueon-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
Can you improve this documentation? These fine people already did:
Zach Tellman, Matthew Davidson & ztellmanEdit on GitHub
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close