v1.7.0
Features
Allow logging for filter()
functions, along with forwarding of errors from it to the onStepFinished hook
Bug fixes
reduce()
now won't cause a -1 effect on the Backpressure
This bug would cause the backpressure to be considering itemsFlowing as -1 after each run that got a reduce operation.
It got fixed and tests were written to avoid this ever happening again.