Skip to content

Commit 53cde33

Browse files
authored
fixed for issue #7001 (#7028)
1 parent b345254 commit 53cde33

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableGroupByTest.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2667,19 +2667,17 @@ public void issue6974Part2Case2Loop() {
26672667

26682668
static void issue6974RunPart2NoEvict(int groupByBufferSize, int flatMapMaxConcurrency, int groups,
26692669
boolean notifyOnExplicitEviction) {
2670-
TestSubscriber<Integer> ts = Flowable
2670+
2671+
Flowable
26712672
.range(1, 500_000)
26722673
.map(i -> i % groups)
26732674
.groupBy(i -> i)
26742675
.flatMap(gf -> gf
26752676
.take(10, TimeUnit.MILLISECONDS)
26762677
, flatMapMaxConcurrency)
2677-
.test();
2678-
2679-
ts
2678+
.subscribeWith(new TestSubscriberEx<>())
26802679
.awaitDone(5, TimeUnit.SECONDS)
2681-
.assertNoErrors()
2682-
.assertComplete();
2680+
.assertTerminated(); // MBE is possible if the async group closing is slow
26832681
}
26842682

26852683
@Test

0 commit comments

Comments
 (0)