Skip to content

Commit 5c3d4c6

Browse files
RomanWuattierakarnokd
authored andcommitted
Have unit tests extends RxJavaTest - 3 (#6595)
This commit updates the unit tests of the following operators: * single * subjects * subscribers And for internal operators: * internal.disposable * internal.fuctions * internal.observers * internal.queue * interanl.schedulers * internal.subscribers * internal.subscriptions * internal.operator.completable Related: #6583
1 parent 177d468 commit 5c3d4c6

File tree

141 files changed

+248
-1082
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

141 files changed

+248
-1082
lines changed

src/test/java/io/reactivex/BackpressureEnumTest.java

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

2222
import io.reactivex.annotations.BackpressureKind;
2323

24-
public class BackpressureEnumTest {
24+
public class BackpressureEnumTest extends RxJavaTest {
2525

2626
@Test
2727
public void backpressureOverflowStrategy() {

src/test/java/io/reactivex/ConverterTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
import io.reactivex.exceptions.TestException;
2121
import io.reactivex.parallel.*;
2222

23-
public final class ConverterTest {
23+
public final class ConverterTest extends RxJavaTest {
2424

2525
@Test
2626
public void flowableConverterThrows() {

src/test/java/io/reactivex/NotificationTest.java

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

2020
import io.reactivex.exceptions.TestException;
2121

22-
public class NotificationTest {
22+
public class NotificationTest extends RxJavaTest {
2323

2424
@Test
2525
public void valueOfOnErrorIsNull() {

src/test/java/io/reactivex/TransformerTest.java

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

2020
import static org.junit.Assert.*;
2121

22-
public class TransformerTest {
22+
public class TransformerTest extends RxJavaTest {
2323

2424
@Test
2525
public void flowableTransformerThrows() {

src/test/java/io/reactivex/XFlatMapTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
import io.reactivex.subscribers.TestSubscriber;
3030
import io.reactivex.testsupport.TestHelper;
3131

32-
public class XFlatMapTest {
32+
public class XFlatMapTest extends RxJavaTest {
3333

3434
@Rule
3535
public Retry retry = new Retry(5, 1000, true);

src/test/java/io/reactivex/internal/SubscribeWithTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
import io.reactivex.observers.TestObserver;
2222
import io.reactivex.subscribers.TestSubscriber;
2323

24-
public class SubscribeWithTest {
24+
public class SubscribeWithTest extends RxJavaTest {
2525

2626
@Test
2727
public void withFlowable() {

src/test/java/io/reactivex/internal/disposables/ArrayCompositeDisposableTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,13 @@
1515

1616
import static org.junit.Assert.*;
1717

18+
import io.reactivex.RxJavaTest;
1819
import org.junit.Test;
1920

2021
import io.reactivex.disposables.*;
2122
import io.reactivex.testsupport.TestHelper;
2223

23-
public class ArrayCompositeDisposableTest {
24+
public class ArrayCompositeDisposableTest extends RxJavaTest {
2425

2526
@Test
2627
public void normal() {

src/test/java/io/reactivex/internal/disposables/CancellableDisposableTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,14 +18,15 @@
1818
import java.util.List;
1919
import java.util.concurrent.atomic.AtomicInteger;
2020

21+
import io.reactivex.RxJavaTest;
2122
import org.junit.Test;
2223

2324
import io.reactivex.exceptions.TestException;
2425
import io.reactivex.functions.Cancellable;
2526
import io.reactivex.plugins.RxJavaPlugins;
2627
import io.reactivex.testsupport.TestHelper;
2728

28-
public class CancellableDisposableTest {
29+
public class CancellableDisposableTest extends RxJavaTest {
2930

3031
@Test
3132
public void normal() {

src/test/java/io/reactivex/internal/disposables/DisposableHelperTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,14 @@
1818
import java.util.List;
1919
import java.util.concurrent.atomic.AtomicReference;
2020

21+
import io.reactivex.RxJavaTest;
2122
import org.junit.Test;
2223

2324
import io.reactivex.disposables.*;
2425
import io.reactivex.plugins.RxJavaPlugins;
2526
import io.reactivex.testsupport.TestHelper;
2627

27-
public class DisposableHelperTest {
28+
public class DisposableHelperTest extends RxJavaTest {
2829
@Test
2930
public void enumMethods() {
3031
assertEquals(1, DisposableHelper.values().length);

src/test/java/io/reactivex/internal/disposables/EmptyDisposableTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,12 +15,13 @@
1515

1616
import static org.junit.Assert.*;
1717

18+
import io.reactivex.RxJavaTest;
1819
import org.junit.Test;
1920

2021
import io.reactivex.internal.fuseable.*;
2122
import io.reactivex.testsupport.TestHelper;
2223

23-
public class EmptyDisposableTest {
24+
public class EmptyDisposableTest extends RxJavaTest {
2425

2526
@Test
2627
public void noOffer() {

0 commit comments

Comments
 (0)