v7.0.0

Code improvements

Expose single thread consumer constructor
Add go.mod

Delete go.mod

v6.3.0

Delete go.mod

Make debouncer param better

debounce better (#14)

Co-authored-by: Gennaro Del Sorbo <[email protected]>

Fix go.mod

6.1.2

fix go mod

Do not reset timer param for debounce handler

Exposed WithDebounceDoNotResetTimer param (default: false). If enabled will execute the first received message when the time window expires.
Incoming new messages within the time window will be discarded.

Debounced fix

v6.0.1

bugfix

More efficient round robin handler

Added an ad-hoc round robin handler where the pool of goroutines runs on top of a single channel.
Constructor: NewRoundRobinHandler(...)

Debounced handler

Exposed a new method HandleDebounced that will handle messages with the same key within a time window only once, only the last message will processed and the rest will be dropped.

Unsigned

Use unsigned to ensure positive partitions

Fix possible race

Fix possible race happening reading number of messages in flight