Skip to content

v0.2.0

Choose a tag to compare

View all tags
@pabloos pabloos released this 10 Sep 19:48
· 10 commits to main since this release
v0.2.0
27e2e3d

Backward-compatible with v0.1.0.

New

  • RunPartitioned — route inputs to workers by key: same key → same worker, processed in order and never concurrently. For per-key ordering or per-key stateful processors. Combine with Ordered() for global order on top.
  • Prefetch(n) — in-flight window so the producer can run ahead of the pool.

Docs

  • Runnable Example tests (run in CI, shown on pkg.go.dev) and a complete package main program in the README.
Assets 2
Loading