What's Changed
- Fixed clearing back-pressure if a
Queue
was completed while containing emitted values which had not been consumed, then the consumer explicitly disposed (calledConcurrentIterator::dispose()
) of the associated iterator without consuming those values. Prior, the futures were not properly resolved with aDisposedException
, but now will resolve as expected.
Full Changelog: v1.2.1...v1.2.2