Change Log

[0.0.0] 2021-12-23

• Rename reductions* to selecting-reductions*
• Add reductions pipeline
• Add round-robin!
• Add wide pipeline async
• Add delay pipe
• Add dataflow

[0.0.7] - 2021-01-13

• BREAKING CHANGE: remove clojure name from all namespaces

[0.0.5]

• add waiting conventions
• Rename all core function
• Fix bugs in batch
• Reductions api similar to transduce
• Add circleci integration

[0.0.4] - 2020-04-05

Changed

• produce/consume api rewrite.

Added

• Out of order pipeline implementation.
• future-like api around produce/consume functions.

Removed

• produce-bound-blocking

[0.0.3] - 2019-12-14

Added

• reductions: publishes reductions of inputs to output channel.
• mux macro: multiplex input channel into maps.
• documentation improvements

WIP

• Kafka example

[Unreleased] - 2019-11-08

Added

• Control function wrappers

[0.0.2-alpha] - 2019-11-04

Version

• Bump for release

Added

• Usage in README

[Unreleased] - 2019-11-02

Add

• merge! and fan!

[Unreleased] - 2019-10-31

Add

• Blocking implementations separate from threads creation.
• tests

Refactor

• Update docstrings.
• Break bindings from go-loop to let inside go-loop.
• split blocking implementations from thread creation to allow threading model choice.

[0.0.1-alpha] - 2019-10-29

Added

• initial produce, consume and split implementation