fixed for issue ReactiveX#7001 (ReactiveX#7028)

ddunig2 · web-flow · commit 53cde33515ee · 2020-07-13T20:30:45.000+02:00
diff --git a/src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableGroupByTest.java b/src/test/java/io/reactivex/rxjava3/internal/operators/flowable/FlowableGroupByTest.java
@@ -2667,19 +2667,17 @@ public void issue6974Part2Case2Loop() {
 
     static void issue6974RunPart2NoEvict(int groupByBufferSize, int flatMapMaxConcurrency, int groups,
             boolean notifyOnExplicitEviction) {
-        TestSubscriber<Integer> ts = Flowable
+    	
+        Flowable
         .range(1, 500_000)
         .map(i -> i % groups)
         .groupBy(i -> i)
         .flatMap(gf -> gf
                 .take(10, TimeUnit.MILLISECONDS)
                 , flatMapMaxConcurrency)
-        .test();
-
-        ts
+        .subscribeWith(new TestSubscriberEx<>())
         .awaitDone(5, TimeUnit.SECONDS)
-        .assertNoErrors()
-        .assertComplete();
+        .assertTerminated(); // MBE is possible if the async group closing is slow
     }
 
     @Test
