diff --git a/src/test/java/io/reactivex/internal/operators/flowable/FlowableIgnoreElementsTest.java b/src/test/java/io/reactivex/internal/operators/flowable/FlowableIgnoreElementsTest.java
index 9edbee59be..5a952c15d0 100644
--- 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
index 3a20768df1..eddaa079dc 100644
--- 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
index 2f62477949..52513fa2f3 100644
--- 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);