The GitHub Actions job "Scalafmt" on 
pekko.git/fix/3459-demand-replenishment-regression has failed.
Run started by GitHub user He-Pin (triggered by He-Pin).

Head commit for run:
df01826547bc3eeb18b76cf2ec4b290edad236d9 / 虎鸣 <[email protected]>
refactor: simplify onNext to unconditional tryOnNext

Motivation:
The previous fix retained a branch on boundarySubscriber that bypassed
tryOnNext's SignalThrewException wrapper. Since batching is removed,
the boundarySubscriber distinction is unnecessary.

Modification:
Remove the boundarySubscriber field and its usages. Use
tryOnNext(subscriber, elem) unconditionally, which is exactly the
pre-M4 code path with proper Reactive Streams error handling.

Result:
Simpler code, consistent error handling, identical behavior to M3.

Tests:
- sbt "stream-tests / Test / testOnly org.apache.pekko.stream.FusingSpec" -- 
20/20 passed
- sbt "stream / mimaReportBinaryIssues" -- passed

References:
Refs #3459

Report URL: https://github.com/apache/pekko/actions/runs/32699665936

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to