clojure.core.async.lab — cnuernber/depsviz 0.7

core.async HIGHLY EXPERIMENTAL feature exploration

Caveats:

1. Everything defined in this namespace is experimental, and subject to change or deletion without warning.

2. Many features provided by this namespace are highly coupled to implementation details of core.async. Potential features which operate at higher levels of abstraction are suitable for inclusion in the examples.

3. Features provided by this namespace MAY be promoted to clojure.core.async at a later point in time, but there is no guarantee any of them will.

broadcast clj

(broadcast & ports)

Returns a broadcasting write port which, when written to, writes the value to each of ports.

Writes to the broadcasting port will park until the value is written to each of the ports used to create it. For this reason, it is strongly advised that each of the underlying ports support buffered writes.

multiplex clj

(multiplex & ports)

Returns a multiplexing read port which, when read from, produces a value from one of ports.

If at read time only one port is available to be read from, the multiplexing port will return that value. If multiple ports are available to be read from, the multiplexing port will return one value from a port chosen non-deterministicly. If no port is available to be read from, parks execution until a value is available.