Skip to content

Commit 8af68ce

Browse files
authored
[test] Cover missed case in FluxReplayStressTest (#3841)
Follow-up after #3707.
1 parent 9e57991 commit 8af68ce

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

reactor-core/src/jcstress/java/reactor/core/publisher/FluxReplayStressTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,11 +82,12 @@ public RefCntConcurrentSubscriptionBaseStressTest(Flux<T> sourceToShare,
8282
" and onError instead of onComplete. The second connect call may still" +
8383
" happen, since ConnectableFlux.subscribe happens before the check of" +
8484
" the current connection value in FluxRefCnt")
85-
@Outcome(id = {"0, 0, 0, 0, 0, 1, 2"}, expect = ACCEPTABLE_INTERESTING, desc =
85+
@Outcome(id = {"0, 0, 0, 0, 0, 1, [1,2]"}, expect = ACCEPTABLE_INTERESTING, desc =
8686
"Expected corner case when the second subscriber still joins the first" +
8787
" subscription, but due to natural concurrency, cancellation of the" +
8888
" first subscriber happens before the value is delivered. In that case" +
89-
" onError is delivered instead of any values")
89+
" onError is delivered instead of any values. The second connect" +
90+
" call may still happen.")
9091
@State
9192
public static class RefCntRaceSubscribeAndCancelNoTimeoutStressTest {
9293

0 commit comments

Comments
 (0)