Replace 'resource' observers with plain 'disposable' observers in tes…

…ts. (#4625)
ReactiveX · Sep 28, 2016 · 64f335c · 64f335c
1 parent a28b558
commit 64f335c
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/test/java/io/reactivex/internal/operators/flowable/FlowableIgnoreElementsTest.java b/src/test/java/io/reactivex/internal/operators/flowable/FlowableIgnoreElementsTest.java
@@ -221,7 +221,7 @@ public void accept(Integer t) {
                 //
                 .ignoreElements()
                 //
-                .subscribe(new ResourceCompletableObserver() {
+                .subscribe(new DisposableCompletableObserver() {
                     @Override
                     public void onComplete() {
                     }

diff --git a/src/test/java/io/reactivex/internal/operators/observable/ObservableBufferTest.java b/src/test/java/io/reactivex/internal/operators/observable/ObservableBufferTest.java
@@ -763,7 +763,7 @@ public void testBufferWithTimeDoesntUnsubscribeDownstream() throws InterruptedEx
         final Observer<Object> o = TestHelper.mockObserver();
 
         final CountDownLatch cdl = new CountDownLatch(1);
-        ResourceObserver<Object> s = new ResourceObserver<Object>() {
+        DisposableObserver<Object> s = new DisposableObserver<Object>() {
             @Override
             public void onNext(Object t) {
                 o.onNext(t);

diff --git a/src/test/java/io/reactivex/observers/SerializedObserverTest.java b/src/test/java/io/reactivex/observers/SerializedObserverTest.java
@@ -375,7 +375,7 @@ public void onNext(String t) {
         AtomicInteger p2 = new AtomicInteger();
 
         o.onSubscribe(Disposables.empty());
-        ResourceObserver<String> as1 = new ResourceObserver<String>() {
+        DisposableObserver<String> as1 = new DisposableObserver<String>() {
             @Override
             public void onNext(String t) {
                 o.onNext(t);
@@ -392,7 +392,7 @@ public void onComplete() {
             }
         };
 
-        ResourceObserver<String> as2 = new ResourceObserver<String>() {
+        DisposableObserver<String> as2 = new DisposableObserver<String>() {
             @Override
             public void onNext(String t) {
                 o.onNext(t);