amphp/pipeline

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 Queue when the consume disposes of the concurrent iterator

Full Changelog: v1.2.6...v1.2.7

What's Changed

• Fixed incorrect position value returned from the concurrent iterator from a Queue when multiple consumers are waiting for a value and one of those waiting in the middle of the waiting list is cancelled (#23, thanks to @wtsergo)

Full Changelog: v1.2.5...v1.2.6

What's Changed

• Fixed early disposal of iterator created with Pipeline::generate()
• Fixed inverted return value of isComplete() on iterator returned from Pipeline::concat()
• Fixed termination of pipelines when concurrency > 1 when the source throws and another concurrent coroutine already completed the pipeline
• Fixed the call ordering on an initial pipeline operator if the source is async
• Improved the garbage collection speed of concurrent pipelines when terminated early

Full Changelog: v1.2.4...v1.2.5

What's Changed

• Return static in methods that return self<T> by @vudaltsov in #24
• Add #[Override] attributes

New Contributors

• @vudaltsov made their first contribution in #24

Full Changelog: v1.2.3...v1.2.4

• Fixed failing any pending value consumption when a Queue is disposed (regression in 1.2.2).

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

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 (called ConcurrentIterator::dispose()) of the associated iterator without consuming those values. Prior, the futures were not properly resolved with a DisposedException, but now will resolve as expected.

Full Changelog: v1.2.1...v1.2.2

What's Changed

• Fix a potential race condition when using a Queue to create a ConcurrentIterator. An Error with message "Must call suspend() before calling throw()" was thrown when a Cancellation provided to ConcurrentIterator::continue() was cancelled and the underlying Queue instance was simultaneously completed. See #22.

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

What's Changed

• Added Pipeline::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

• Added Pipeline::merge() which combines multiple iterators, emitting a value whenever any iterator emits a value.
• Fixed Pipeline::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 of ConcurrentIterator as covariant.

Initial stable release 🎉

Changes from 1.0.0 Beta 7

• Marked ConcurrentArrayIterator, ConcurrentChainedIterator, and ConcurrentIterableIterator as @internal. Instead of these classes, use Pipeline::fromIterable() or Pipeline::concat()
• Pipeline::concat() now accepts an array of any iterable, not only other Pipeline objects