From 8cb8f437569948e0992563043fbfbeaabd770f45 Mon Sep 17 00:00:00 2001
From: shikong <919411476@qq.com>
Date: Sun, 5 May 2024 17:27:05 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/cn/skcks/study/rxjava/RxJavaStudyStarterTest.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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);