@@ -2719,10 +2719,9 @@ public void issue6974Part2Case1ObserveOn() {
2719
2719
// .take(10)
2720
2720
.take (10 , TimeUnit .MILLISECONDS )
2721
2721
, flatMapMaxConcurrency )
2722
- .test ( )
2722
+ .subscribeWith ( new TestSubscriberEx <>() )
2723
2723
.awaitDone (5 , TimeUnit .SECONDS )
2724
- .assertNoErrors ()
2725
- .assertComplete ();
2724
+ .assertTerminated (); // MBE is possible if the async group closing is slow
2726
2725
}
2727
2726
2728
2727
@ Test
@@ -2746,10 +2745,9 @@ public void issue6974Part2Case1ObserveOnHide() {
2746
2745
// .take(10)
2747
2746
.take (10 , TimeUnit .MILLISECONDS )
2748
2747
, flatMapMaxConcurrency )
2749
- .test ( )
2748
+ .subscribeWith ( new TestSubscriberEx <>() )
2750
2749
.awaitDone (5 , TimeUnit .SECONDS )
2751
- .assertNoErrors ()
2752
- .assertComplete ();
2750
+ .assertTerminated (); // MBE is possible if the async group closing is slow
2753
2751
}
2754
2752
2755
2753
@ Test
@@ -2834,10 +2832,9 @@ public void issue6974Part2Case1ObserveOnConditional() {
2834
2832
// .take(10)
2835
2833
.take (10 , TimeUnit .MILLISECONDS )
2836
2834
, flatMapMaxConcurrency )
2837
- .test ( )
2835
+ .subscribeWith ( new TestSubscriberEx <>() )
2838
2836
.awaitDone (5 , TimeUnit .SECONDS )
2839
- .assertNoErrors ()
2840
- .assertComplete ();
2837
+ .assertTerminated (); // MBE is possible if the async group closing is slow
2841
2838
}
2842
2839
2843
2840
@ Test
@@ -2862,10 +2859,9 @@ public void issue6974Part2Case1ObserveOnConditionalHide() {
2862
2859
// .take(10)
2863
2860
.take (10 , TimeUnit .MILLISECONDS )
2864
2861
, flatMapMaxConcurrency )
2865
- .test ( )
2862
+ .subscribeWith ( new TestSubscriberEx <>() )
2866
2863
.awaitDone (5 , TimeUnit .SECONDS )
2867
- .assertNoErrors ()
2868
- .assertComplete ();
2864
+ .assertTerminated (); // MBE is possible if the async group closing is slow
2869
2865
}
2870
2866
2871
2867
/*
0 commit comments