diff --git a/starter/src/test/java/cn/skcks/study/rxjava/RxJavaStudyStarterTest.java b/starter/src/test/java/cn/skcks/study/rxjava/RxJavaStudyStarterTest.java
index b37e014..bd529e4 100644
--- a/starter/src/test/java/cn/skcks/study/rxjava/RxJavaStudyStarterTest.java
+++ b/starter/src/test/java/cn/skcks/study/rxjava/RxJavaStudyStarterTest.java
@@ -157,7 +157,8 @@ public class RxJavaStudyStarterTest {
             Thread.sleep(200);
             emitter.onNext("World");
             emitter.onComplete();
-        }, BackpressureStrategy.LATEST);
+        }, BackpressureStrategy.LATEST)
+                .subscribeOn(Schedulers.io());
 
         // 缓存数据
         observable = observable.cacheWithInitialCapacity(1);