He-Pin opened a new pull request, #3296: URL: https://github.com/apache/pekko/pull/3296
### Motivation Async boundary batching should preserve elements already produced by an upstream stage before that stage fails. ### Modification Add a focused FusingSpec regression using transformed string elements upstream of an async boundary, then assert the already emitted elements arrive before the failure. ### Result Async boundary failure-draining behavior has a direct regression test. ### Tests - rtk scalafmt --mode diff-ref=origin/main -- passed - rtk scalafmt --list --mode diff-ref=origin/main -- passed - rtk git diff --check -- passed - rtk sbt "stream-tests / Test / testOnly org.apache.pekko.stream.FusingSpec -- -z \"deliver transformed elements already produced\"" -- passed, 1 test - qodercli stdout review of /tmp/project-review.diff -- passed, no must-fix findings ### References None - regression coverage for async boundary batching -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
