Skip to content

Commit

Permalink
Merge #3841 into 3.6.8
Browse files Browse the repository at this point in the history
  • Loading branch information
chemicL committed Jul 8, 2024
2 parents 53f9251 + 3715e57 commit db670eb
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -82,11 +82,12 @@ public RefCntConcurrentSubscriptionBaseStressTest(Flux<T> sourceToShare,
" and onError instead of onComplete. The second connect call may still" +
" happen, since ConnectableFlux.subscribe happens before the check of" +
" the current connection value in FluxRefCnt")
@Outcome(id = {"0, 0, 0, 0, 0, 1, 2"}, expect = ACCEPTABLE_INTERESTING, desc =
@Outcome(id = {"0, 0, 0, 0, 0, 1, [1,2]"}, expect = ACCEPTABLE_INTERESTING, desc =
"Expected corner case when the second subscriber still joins the first" +
" subscription, but due to natural concurrency, cancellation of the" +
" first subscriber happens before the value is delivered. In that case" +
" onError is delivered instead of any values")
" onError is delivered instead of any values. The second connect" +
" call may still happen.")
@State
public static class RefCntRaceSubscribeAndCancelNoTimeoutStressTest {

Expand Down

0 comments on commit db670eb

Please sign in to comment.