File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
src/test/java/io/reactivex/rxjava4/internal/operators/flowable Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change 2020
2121import java .util .*;
2222import java .util .concurrent .*;
23+ import java .util .concurrent .Flow .*;
2324import java .util .concurrent .atomic .*;
2425
2526import org .junit .*;
26- import static java . util . concurrent . Flow .* ;
27+ import org . junit . jupiter . api . parallel . Isolated ;
2728
2829import io .reactivex .rxjava4 .core .*;
2930import io .reactivex .rxjava4 .core .Scheduler .Worker ;
3940import io .reactivex .rxjava4 .subscribers .*;
4041import io .reactivex .rxjava4 .testsupport .*;
4142
43+ @ Isolated
4244public class FlowableMergeTest extends RxJavaTest {
4345
4446 Subscriber <String > stringSubscriber ;
@@ -213,7 +215,7 @@ public void mergeArrayWithThreading() {
213215 verify (stringSubscriber , times (1 )).onComplete ();
214216 }
215217
216- @ Test
218+ @ org . junit . jupiter . api . Test
217219 public void synchronizationOfMultipleSequencesLoop () throws Throwable {
218220 for (int i = 0 ; i < 100 ; i ++) {
219221 System .out .println ("testSynchronizationOfMultipleSequencesLoop > " + i );
You can’t perform that action at this time.
0 commit comments