测试

2024-05-05 17:27:05 +08:00 · 2024-05-05 17:27:05 +08:00 · 8cb8f43756
commit 8cb8f43756
parent c50667380a
1 changed files with 2 additions and 1 deletions
--- 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);