1.0.0 Beta 5
Pre-release
Pre-release
- Added
isComplete()
to theConcurrentIterator
interface that returnstrue
when the iterator has been completed (either successfully or with an error) and no further values are pending) - Fixed an issue where a reference to the prior value emitted on a
ConcurrentIterator
was held while awaiting the next value.