Skip to content

Commit 8415275

Browse files
committed
Last set of Flow unit test conversion
1 parent 7dab4c7 commit 8415275

37 files changed

Lines changed: 37 additions & 37 deletions

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableSkipTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import java.util.concurrent.atomic.AtomicLong;
2323

2424
import org.junit.Test;
25-
import org.reactivestreams.Subscriber;
25+
import static java.util.concurrent.Flow.*;
2626

2727
import io.reactivex.rxjava4.core.*;
2828
import io.reactivex.rxjava4.functions.*;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableSkipTimedTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020

2121
import org.junit.Test;
2222
import org.mockito.InOrder;
23-
import org.reactivestreams.Subscriber;
23+
import static java.util.concurrent.Flow.*;
2424

2525
import io.reactivex.rxjava4.core.*;
2626
import io.reactivex.rxjava4.exceptions.TestException;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableSkipUntilTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
import static org.mockito.Mockito.*;
1818

1919
import org.junit.*;
20-
import org.reactivestreams.Subscriber;
20+
import static java.util.concurrent.Flow.*;
2121

2222
import io.reactivex.rxjava4.core.*;
2323
import io.reactivex.rxjava4.functions.Function;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableSkipWhileTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818

1919
import org.junit.Test;
2020
import org.mockito.InOrder;
21-
import org.reactivestreams.Subscriber;
21+
import static java.util.concurrent.Flow.*;
2222

2323
import io.reactivex.rxjava4.core.*;
2424
import io.reactivex.rxjava4.exceptions.TestException;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableSubscribeOnTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import java.util.concurrent.atomic.*;
2020

2121
import org.junit.Test;
22-
import org.reactivestreams.*;
22+
import static java.util.concurrent.Flow.*;
2323

2424
import io.reactivex.rxjava4.annotations.NonNull;
2525
import io.reactivex.rxjava4.core.*;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableSwitchIfEmptyTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
import java.util.concurrent.atomic.AtomicBoolean;
2121

2222
import org.junit.Test;
23-
import org.reactivestreams.*;
23+
import static java.util.concurrent.Flow.*;
2424

2525
import io.reactivex.rxjava4.core.*;
2626
import io.reactivex.rxjava4.functions.Consumer;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableSwitchTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323

2424
import org.junit.*;
2525
import org.mockito.InOrder;
26-
import org.reactivestreams.*;
26+
import static java.util.concurrent.Flow.*;
2727

2828
import io.reactivex.rxjava4.core.*;
2929
import io.reactivex.rxjava4.exceptions.*;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableTakeLastTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323

2424
import org.junit.Test;
2525
import org.mockito.InOrder;
26-
import org.reactivestreams.*;
26+
import static java.util.concurrent.Flow.*;
2727

2828
import io.reactivex.rxjava4.annotations.NonNull;
2929
import io.reactivex.rxjava4.core.*;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableTakeLastTimedTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020

2121
import org.junit.Test;
2222
import org.mockito.InOrder;
23-
import org.reactivestreams.*;
23+
import static java.util.concurrent.Flow.*;
2424

2525
import io.reactivex.rxjava4.core.*;
2626
import io.reactivex.rxjava4.exceptions.TestException;

src/test/java/io/reactivex/rxjava4/internal/operators/flowable/FlowableTakeTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323

2424
import org.junit.Test;
2525
import org.mockito.InOrder;
26-
import org.reactivestreams.*;
26+
import static java.util.concurrent.Flow.*;
2727

2828
import io.reactivex.rxjava4.core.*;
2929
import io.reactivex.rxjava4.exceptions.TestException;

0 commit comments

Comments
 (0)