What's Changed
- Fixed consuming a value from the concurrent iterator returned from
Pipeline::generate()if consumption of the prior emitted value was cancelled in the same event-loop tick - Fixed relieving back-pressure from
Queuewhen the consume disposes of the concurrent iterator
Full Changelog: v1.2.6...v1.2.7