• Fixed failing any pending value consumption when aQueue is disposed (regression in1.2.2).

Full Changelog:v1.2.2...v1.2.3

What's Changed

• Fixed clearing back-pressure if aQueue 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

What's Changed

• Fix a potential race condition when using aQueue to create aConcurrentIterator. AnError with message "Must call suspend() before calling throw()" was thrown when aCancellation provided toConcurrentIterator::continue() was cancelled and the underlyingQueue instance was simultaneously completed. See#22.

Full Changelog:v1.2.0...v1.2.1

What's Changed

• AddedPipeline::buffer(), which provides control of the number of values buffered by the pipeline before back-pressure is applied to the data source by@trowski in#21

Full Changelog:v1.1.0...v1.2.0

Contributors

• AddedPipeline::merge() which combines multiple iterators, emitting a value whenever any iterator emits a value.
• FixedPipeline::take() not completing until a value beyond the given count was emitted. The pipeline now completes immediately after emitting the last view.
• Marked the template type ofConcurrentIterator as covariant.

Initial stable release 🎉

Changes from 1.0.0 Beta 7

• MarkedConcurrentArrayIterator,ConcurrentChainedIterator, andConcurrentIterableIterator as@internal. Instead of these classes, usePipeline::fromIterable() orPipeline::concat()
• Pipeline::concat() now accepts an array of anyiterable, not only otherPipeline objects

• Removed failing aQueue that is destructed without being completed. PHP's random destruct order sometimes will lead to theQueue destructor being invoked before another destructor that would have completed the queue.

• Add compatibility with Revolt v1.x
• ImproveConcurrentIterableIterator

• AddedisComplete() 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 aConcurrentIterator was held while awaiting the next value.

• PHP 8.1 is now required.
• Fixed circular references inConcurrentIterableIterator andConcurrentFlatMapIterator that prevented quick garbage collection, particularly problematic with instances created fromPipeline::fromIterable() using a generator.