What's Changed
- Fixed early disposal of iterator created with
Pipeline::generate() - Fixed inverted return value of
isComplete()on iterator returned fromPipeline::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