The GitHub Actions job "Pull Requests" on 
pekko.git/copilot/fix-intermittent-test-failure has failed.
Run started by GitHub user Copilot (triggered by pjfanning).

Head commit for run:
f11feeed12e4c1724e974cf91348206009c58266 / copilot-swe-agent[bot] 
<[email protected]>
Rewrite HubSpec sequential consumer test to eliminate race condition

The test 'ensure that subsequent consumers see subsequent elements without
gap' was flaky because it cancelled the first consumer via a callback that
fires INSIDE RegistrationPending processing. The cancel is asynchronous,
so UnRegister arrives at the hub AFTER RegistrationPending has already
read a stale head value, causing consumer 2 to start from the wrong offset.

Rewrite the test to let consumer 1 complete naturally via take(10). Pekko's
GraphStageLogic.internalCompleteStage processes inlets (cancel) before
outlets (complete), so the hub's UnRegister is enqueued in the hub actor's
mailbox before Sink.seq's postStop resolves the future. Consumer 2's
RegistrationPending is only sent after futureValue returns, guaranteeing
the hub processes UnRegister → head advanced before RegistrationPending.

Remove now-unused imports: AtomicInteger, AtomicReference, @nowarn.
No production code changes.

Agent-Logs-Url: 
https://github.com/pjfanning/incubator-pekko/sessions/0ed4c2ab-7f82-4e08-85af-f4b061725c67

Co-authored-by: pjfanning <[email protected]>

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

With regards,
GitHub Actions via GitBox


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

Reply via email to