Use test() helpers

ReactiveX · Nov 19, 2017 · e0d793f · e0d793f
1 parent 5c3bdf3
commit e0d793f
Showing 1 changed file with 20 additions and 22 deletions.
diff --git a/src/test/java/io/reactivex/completable/CompletableTest.java b/src/test/java/io/reactivex/completable/CompletableTest.java
@@ -2783,32 +2783,30 @@ public void timeoutOtherNull() {
 
     @Test(timeout = 5000)
     public void toNormal() {
-        Flowable<Object> flow = normal.completable.to(new Function<Completable, Flowable<Object>>() {
-            @Override
-            public Flowable<Object> apply(Completable c) {
-                return c.toFlowable();
-            }
-        });
-
-        flow.blockingForEach(new Consumer<Object>() {
-            @Override
-            public void accept(Object e) { }
-        });
+        normal.completable
+                .to(new Function<Completable, Flowable<Object>>() {
+                    @Override
+                    public Flowable<Object> apply(Completable c) {
+                        return c.toFlowable();
+                    }
+                })
+                .test()
+                .assertComplete()
+                .assertNoValues();
     }
 
     @Test(timeout = 5000)
     public void asNormal() {
-        Flowable<Object> flow = normal.completable.as(new CompletableConverter<Flowable<Object>>() {
-            @Override
-            public Flowable<Object> apply(Completable c) {
-                return c.toFlowable();
-            }
-        });
-
-        flow.blockingForEach(new Consumer<Object>() {
-            @Override
-            public void accept(Object e) { }
-        });
+        normal.completable
+                .as(new CompletableConverter<Flowable<Object>>() {
+                    @Override
+                    public Flowable<Object> apply(Completable c) {
+                        return c.toFlowable();
+                    }
+                })
+                .test()
+                .assertComplete()
+                .assertNoValues();
     }
 
     @Test