Composable bounded fan-out for finite or externally cancellable streams.
Fan-out handles and branches are opaque Closeable resources. Own them with
with-open, consume each branch once, and use stats for distribution
metrics. The public contract does not expose the internal queue backend.
Composable bounded fan-out for finite or externally cancellable streams. Fan-out handles and branches are opaque Closeable resources. Own them with `with-open`, consume each branch once, and use `stats` for distribution metrics. The public contract does not expose the internal queue backend.
(branch fanout branch-id)Acquire a named single-consumer branch from fanout.
A branch is opaque, Seqable, reducible, and java.io.Closeable. Each branch
ID may be acquired once. Closing a branch does not close sibling branches.
Acquire a named single-consumer branch from `fanout`. A branch is opaque, Seqable, reducible, and `java.io.Closeable`. Each branch ID may be acquired once. Closing a branch does not close sibling branches.
(fan-out source branches)(fan-out source branches opts)Start bounded distribution of every source value to named branches.
source must be seqable. branches must be a map of at least two keyword
IDs to configs. Every config requires :buffer-mode (:blocking or
:dropping) and may set positive :buffer-cap (default 1024).
Options:
:cancel! releases an externally waiting source during shutdown.:close-timeout-ms bounds the dispatcher wait during close.Returns an opaque java.io.Closeable fan-out handle.
Start bounded distribution of every source value to named branches. `source` must be seqable. `branches` must be a map of at least two keyword IDs to configs. Every config requires `:buffer-mode` (`:blocking` or `:dropping`) and may set positive `:buffer-cap` (default 1024). Options: - `:cancel!` releases an externally waiting source during shutdown. - `:close-timeout-ms` bounds the dispatcher wait during close. Returns an opaque `java.io.Closeable` fan-out handle.
(stats fanout)Return the data-only, schema-versioned distribution snapshot for fanout.
The snapshot contains source, branch, buffer, drop, backpressure, lifecycle, and data-only error fields. Capture and application metrics remain separate.
Return the data-only, schema-versioned distribution snapshot for `fanout`. The snapshot contains source, branch, buffer, drop, backpressure, lifecycle, and data-only error fields. Capture and application metrics remain separate.
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 |