Have unit tests extends RxJavaTest - 3

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: ReactiveX#6583

Author: RomanWuattier

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

@@ -21,7 +21,7 @@
 
 import io.reactivex.annotations.BackpressureKind;
 
-public class BackpressureEnumTest {
+public class BackpressureEnumTest extends RxJavaTest {
 
     @Test
     public void backpressureOverflowStrategy() {

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

@@ -20,7 +20,7 @@
 import io.reactivex.exceptions.TestException;
 import io.reactivex.parallel.*;
 
-public final class ConverterTest {
+public final class ConverterTest extends RxJavaTest {
 
     @Test
     public void flowableConverterThrows() {

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

@@ -19,7 +19,7 @@
 
 import io.reactivex.exceptions.TestException;
 
-public class NotificationTest {
+public class NotificationTest extends RxJavaTest {
 
     @Test
     public void valueOfOnErrorIsNull() {

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

@@ -19,7 +19,7 @@
 
 import static org.junit.Assert.*;
 
-public class TransformerTest {
+public class TransformerTest extends RxJavaTest {
 
     @Test
     public void flowableTransformerThrows() {

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

@@ -29,7 +29,7 @@
 import io.reactivex.subscribers.TestSubscriber;
 import io.reactivex.testsupport.TestHelper;
 
-public class XFlatMapTest {
+public class XFlatMapTest extends RxJavaTest {
 
     @Rule
     public Retry retry = new Retry(5, 1000, true);

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

@@ -21,7 +21,7 @@
 import io.reactivex.observers.TestObserver;
 import io.reactivex.subscribers.TestSubscriber;
 
-public class SubscribeWithTest {
+public class SubscribeWithTest extends RxJavaTest {
 
     @Test
     public void withFlowable() {

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

@@ -15,12 +15,13 @@
 
 import static org.junit.Assert.*;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.disposables.*;
 import io.reactivex.testsupport.TestHelper;
 
-public class ArrayCompositeDisposableTest {
+public class ArrayCompositeDisposableTest extends RxJavaTest {
 
     @Test
     public void normal() {

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

@@ -18,14 +18,15 @@
 import java.util.List;
 import java.util.concurrent.atomic.AtomicInteger;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.exceptions.TestException;
 import io.reactivex.functions.Cancellable;
 import io.reactivex.plugins.RxJavaPlugins;
 import io.reactivex.testsupport.TestHelper;
 
-public class CancellableDisposableTest {
+public class CancellableDisposableTest extends RxJavaTest {
 
     @Test
     public void normal() {

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

@@ -18,13 +18,14 @@
 import java.util.List;
 import java.util.concurrent.atomic.AtomicReference;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.disposables.*;
 import io.reactivex.plugins.RxJavaPlugins;
 import io.reactivex.testsupport.TestHelper;
 
-public class DisposableHelperTest {
+public class DisposableHelperTest extends RxJavaTest {
     @Test
     public void enumMethods() {
         assertEquals(1, DisposableHelper.values().length);

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

@@ -15,12 +15,13 @@
 
 import static org.junit.Assert.*;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.internal.fuseable.*;
 import io.reactivex.testsupport.TestHelper;
 
-public class EmptyDisposableTest {
+public class EmptyDisposableTest extends RxJavaTest {
 
     @Test
     public void noOffer() {

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

@@ -17,13 +17,14 @@
 
 import java.util.*;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.disposables.*;
 import io.reactivex.exceptions.*;
 import io.reactivex.testsupport.TestHelper;
 
-public class ListCompositeDisposableTest {
+public class ListCompositeDisposableTest extends RxJavaTest {
 
     @Test
     public void constructorAndAddVarargs() {

src/test/java/io/reactivex/internal/functions/FunctionsTest.java

@@ -18,6 +18,7 @@
 import java.lang.reflect.Method;
 import java.util.List;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.exceptions.TestException;
@@ -27,7 +28,7 @@
 import io.reactivex.plugins.RxJavaPlugins;
 import io.reactivex.testsupport.TestHelper;
 
-public class FunctionsTest {
+public class FunctionsTest extends RxJavaTest {
     @Test
     public void utilityClass() {
         TestHelper.checkUtilityClass(Functions.class);

src/test/java/io/reactivex/internal/functions/ObjectHelperTest.java

@@ -13,13 +13,14 @@
 
 package io.reactivex.internal.functions;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.testsupport.TestHelper;
 
 import static org.junit.Assert.*;
 
-public class ObjectHelperTest {
+public class ObjectHelperTest extends RxJavaTest {
 
     @Test
     public void utilityClass() {

src/test/java/io/reactivex/internal/observers/BasicFuseableObserverTest.java

@@ -13,14 +13,15 @@
 
 package io.reactivex.internal.observers;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.annotations.Nullable;
 import io.reactivex.disposables.Disposables;
 import io.reactivex.observers.TestObserver;
 import io.reactivex.testsupport.TestObserverEx;
 
-public class BasicFuseableObserverTest {
+public class BasicFuseableObserverTest extends RxJavaTest {
 
     @Test(expected = UnsupportedOperationException.class)
     public void offer() {

src/test/java/io/reactivex/internal/observers/BasicQueueDisposableTest.java

@@ -13,10 +13,11 @@
 
 package io.reactivex.internal.observers;
 
+import io.reactivex.RxJavaTest;
 import io.reactivex.annotations.Nullable;
 import org.junit.Test;
 
-public class BasicQueueDisposableTest {
+public class BasicQueueDisposableTest extends RxJavaTest {
 
     BasicQueueDisposable<Integer> q = new BasicQueueDisposable<Integer>() {
 

src/test/java/io/reactivex/internal/observers/BlockingFirstObserverTest.java

@@ -15,12 +15,13 @@
 
 import static org.junit.Assert.*;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.disposables.*;
 import io.reactivex.exceptions.TestException;
 
-public class BlockingFirstObserverTest {
+public class BlockingFirstObserverTest extends RxJavaTest {
 
     @Test
     public void firstValueOnly() {

src/test/java/io/reactivex/internal/observers/BlockingMultiObserverTest.java

@@ -17,12 +17,13 @@
 
 import java.util.concurrent.TimeUnit;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.disposables.*;
 import io.reactivex.schedulers.Schedulers;
 
-public class BlockingMultiObserverTest {
+public class BlockingMultiObserverTest extends RxJavaTest {
 
     @Test
     public void dispose() {

src/test/java/io/reactivex/internal/observers/BlockingObserverTest.java

@@ -17,9 +17,10 @@
 
 import java.util.*;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
-public class BlockingObserverTest {
+public class BlockingObserverTest extends RxJavaTest {
 
     @Test
     public void dispose() {

src/test/java/io/reactivex/internal/observers/CallbackCompletableObserverTest.java

@@ -13,12 +13,13 @@
 
 package io.reactivex.internal.observers;
 
+import io.reactivex.RxJavaTest;
 import io.reactivex.internal.functions.Functions;
 import org.junit.Test;
 
 import static org.junit.Assert.*;
 
-public final class CallbackCompletableObserverTest {
+public final class CallbackCompletableObserverTest extends RxJavaTest {
 
     @Test
     public void emptyActionShouldReportNoCustomOnError() {

src/test/java/io/reactivex/internal/observers/ConsumerSingleObserverTest.java

@@ -13,12 +13,13 @@
 
 package io.reactivex.internal.observers;
 
+import io.reactivex.RxJavaTest;
 import io.reactivex.internal.functions.Functions;
 import org.junit.Test;
 
 import static org.junit.Assert.*;
 
-public final class ConsumerSingleObserverTest {
+public final class ConsumerSingleObserverTest extends RxJavaTest {
 
     @Test
     public void onErrorMissingShouldReportNoCustomOnError() {

src/test/java/io/reactivex/internal/observers/DeferredScalarObserverTest.java

@@ -17,6 +17,7 @@
 
 import java.util.List;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.Observer;
@@ -27,7 +28,7 @@
 import io.reactivex.plugins.RxJavaPlugins;
 import io.reactivex.testsupport.*;
 
-public class DeferredScalarObserverTest {
+public class DeferredScalarObserverTest extends RxJavaTest {
 
     static final class TakeFirst extends DeferredScalarObserver<Integer, Integer> {
 

src/test/java/io/reactivex/internal/observers/DisposableLambdaObserverTest.java

@@ -17,6 +17,7 @@
 
 import java.util.List;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import io.reactivex.disposables.Disposables;
@@ -27,7 +28,7 @@
 import io.reactivex.plugins.RxJavaPlugins;
 import io.reactivex.testsupport.TestHelper;
 
-public class DisposableLambdaObserverTest {
+public class DisposableLambdaObserverTest extends RxJavaTest {
 
     @Test
     public void doubleOnSubscribe() {

src/test/java/io/reactivex/internal/observers/EmptyCompletableObserverTest.java

@@ -13,11 +13,12 @@
 
 package io.reactivex.internal.observers;
 
+import io.reactivex.RxJavaTest;
 import org.junit.Test;
 
 import static org.junit.Assert.assertFalse;
 
-public final class EmptyCompletableObserverTest {
+public final class EmptyCompletableObserverTest extends RxJavaTest {
 
     @Test
     public void defaultShouldReportNoCustomOnError() {

src/test/java/io/reactivex/internal/observers/FutureObserverTest.java

@@ -19,6 +19,7 @@
 import java.util.*;
 import java.util.concurrent.*;
 
+import io.reactivex.RxJavaTest;
 import org.junit.*;
 
 import io.reactivex.disposables.*;
@@ -30,7 +31,7 @@
 import io.reactivex.schedulers.Schedulers;
 import io.reactivex.testsupport.TestHelper;
 
-public class FutureObserverTest {
+public class FutureObserverTest extends RxJavaTest {
     FutureObserver<Integer> fo;
 
     @Before

src/test/java/io/reactivex/internal/observers/FutureSingleObserverTest.java

@@ -28,7 +28,7 @@
 import io.reactivex.subjects.PublishSubject;
 import io.reactivex.testsupport.TestHelper;
 
-public class FutureSingleObserverTest {
+public class FutureSingleObserverTest extends RxJavaTest {
 
     @Test
     public void cancel() {

src/test/java/io/reactivex/internal/observers/LambdaObserverTest.java

@@ -18,6 +18,7 @@
 import java.io.IOException;
 import java.util.*;
 
+import io.reactivex.RxJavaTest;
 import io.reactivex.internal.functions.Functions;
 import org.junit.Test;
 
@@ -30,7 +31,7 @@
 import io.reactivex.subjects.PublishSubject;
 import io.reactivex.testsupport.TestHelper;
 
-public class LambdaObserverTest {
+public class LambdaObserverTest extends RxJavaTest {
 
     @Test
     public void onSubscribeThrows() {

src/test/java/io/reactivex/internal/observers/QueueDrainObserverTest.java

@@ -21,7 +21,7 @@
 import io.reactivex.observers.TestObserver;
 import io.reactivex.testsupport.TestHelper;
 
-public class QueueDrainObserverTest {
+public class QueueDrainObserverTest extends RxJavaTest {
 
     static final QueueDrainObserver<Integer, Integer, Integer> createUnordered(TestObserver<Integer> to, final Disposable d) {
         return new QueueDrainObserver<Integer, Integer, Integer>(to, new SpscArrayQueue<Integer>(4)) {

src/test/java/io/reactivex/internal/operators/completable/CompletableAmbTest.java

@@ -34,7 +34,7 @@
 import io.reactivex.subjects.*;
 import io.reactivex.testsupport.TestHelper;
 
-public class CompletableAmbTest {
+public class CompletableAmbTest extends RxJavaTest {
 
     @Test
     public void ambLots() {

src/test/java/io/reactivex/internal/operators/completable/CompletableAndThenCompletableabTest.java

@@ -27,7 +27,7 @@
 
 import static org.junit.Assert.*;
 
-public class CompletableAndThenCompletableabTest {
+public class CompletableAndThenCompletableabTest extends RxJavaTest {
     @Test(expected = NullPointerException.class)
     public void andThenCompletableCompleteNull() {
         Completable.complete()

src/test/java/io/reactivex/internal/operators/completable/CompletableAndThenTest.java

@@ -18,7 +18,7 @@
 import io.reactivex.*;
 import io.reactivex.testsupport.TestHelper;
 
-public class CompletableAndThenTest {
+public class CompletableAndThenTest extends RxJavaTest {
     @Test(expected = NullPointerException.class)
     public void andThenMaybeNull() {
         Completable.complete()