Fix mistakes in observers package info, fix generics

deverhjj · Oct 9, 2017 · 54e9862 · 54e9862
1 parent 1b0cd2a
commit 54e9862
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/src/main/java/io/reactivex/observers/package-info.java b/src/main/java/io/reactivex/observers/package-info.java
@@ -17,7 +17,7 @@
 /**
  * Default wrappers and implementations for Observer-based consumer classes and interfaces,
  * including disposable and resource-tracking variants and
- * the {@link io.reactivex.subscribers.TestObserver} that allows unit testing
+ * the {@link io.reactivex.observers.TestObserver} that allows unit testing
  * {@link io.reactivex.Observable}-, {@link io.reactivex.Single}-, {@link io.reactivex.Maybe}-
  * and {@link io.reactivex.Completable}-based flows.
  */

diff --git a/...t/java/io/reactivex/internal/operators/observable/ObservableConcatMapCompletableTest.java b/...t/java/io/reactivex/internal/operators/observable/ObservableConcatMapCompletableTest.java
@@ -34,7 +34,7 @@ public class ObservableConcatMapCompletableTest {
     public void asyncFused() throws Exception {
         UnicastSubject<Integer> us = UnicastSubject.create();
 
-        TestObserver to = us.concatMapCompletable(completableComplete(), 2).test();
+        TestObserver<Void> to = us.concatMapCompletable(completableComplete(), 2).test();
 
         us.onNext(1);
         us.onComplete();
@@ -46,7 +46,7 @@ public void asyncFused() throws Exception {
     @Test
     public void notFused() throws Exception {
         UnicastSubject<Integer> us = UnicastSubject.create();
-        TestObserver to = us.hide().concatMapCompletable(completableComplete(), 2).test();
+        TestObserver<Void> to = us.hide().concatMapCompletable(completableComplete(), 2).test();
 
         us.onNext(1);
         us.onNext(2);
@@ -113,7 +113,7 @@ public void onErrorRace() {
                 final PublishSubject<Integer> ps1 = PublishSubject.create();
                 final PublishSubject<Integer> ps2 = PublishSubject.create();
 
-                TestObserver to = ps1.concatMapCompletable(new Function<Integer, CompletableSource>() {
+                TestObserver<Void> to = ps1.concatMapCompletable(new Function<Integer, CompletableSource>() {
                     @Override
                     public CompletableSource apply(Integer v) throws Exception {
                         return Completable.fromObservable(ps2);
@@ -172,7 +172,6 @@ public Integer apply(Integer v) throws Exception {
         .assertFailure(TestException.class);
     }
 
-    @SuppressWarnings("unchecked")
     @Test
     public void concatReportsDisposedOnComplete() {
         final Disposable[] disposable = { null };
@@ -199,7 +198,6 @@ public void onComplete() {
         assertTrue(disposable[0].isDisposed());
     }
 
-    @SuppressWarnings("unchecked")
     @Test
     public void concatReportsDisposedOnError() {
         final Disposable[] disposable = { null };