订阅时的RxJava NetworkOnMainThreadException
是指在Android开发中使用RxJava进行网络请求时，由于在主线程中执行网络请求导致的异常。在Android开发中，主线程（也称为UI线程）主要负责处理用户界面的更新和响应用户交互事件，如果在主线程中执行耗时的网络请求操作，会导致界面卡顿、无响应等问题，影响用户体验。
为了避免在主线程中执行网络请求，可以使用RxJava的线程调度功能来切换到后台线程执行网络请求操作。常见的线程调度方法包括：
- subscribeOn(Schedulers.io()): 将Observable的创建和订阅过程切换到io线程，适用于耗时的IO操作，如网络请求。
- observeOn(AndroidSchedulers.mainThread()): 将Observable的事件回调切换到主线程，以便在主线程中更新UI。
通过正确使用线程调度，可以避免在主线程中执行网络请求而引发的NetworkOnMainThreadException异常。
RxJava是一种基于观察者模式的异步编程库，它提供了丰富的操作符和线程调度功能，使得异步编程更加简洁和灵活。RxJava广泛应用于Android开发中的网络请求、事件处理、数据流转等场景。
在腾讯云的产品中，可以使用腾讯云提供的云函数（SCF）来执行后台的网络请求操作。云函数是一种无服务器计算服务，可以在云端运行代码逻辑，无需关心服务器的搭建和维护。通过使用云函数，可以将网络请求等耗时操作放在云端执行，从而避免在移动设备上的主线程中执行网络请求。
腾讯云云函数产品介绍链接：https://cloud.tencent.com/product/scf
总结： 订阅时的RxJava NetworkOnMainThreadException是指在Android开发中使用RxJava进行网络请求时，由于在主线程中执行网络请求导致的异常。为了避免该异常，可以使用RxJava的线程调度功能将网络请求切换到后台线程执行。腾讯云提供的云函数（SCF）是一种无服务器计算服务，可以用于执行后台的网络请求操作。
相关·内容
我试图从一个api中获取列表，并使用RxJava重新配置在回收视图中显示。
我用了下面的代码-
ApiInterface apiService =
ApiService.getClient().create(ApiInterface.class);
Observable<MoviesResponse> call = apiService.getTopRatedMovies(API_KEY);
call.subscribeOn(Schedulers.newThread())
.observeOn(Android
浏览 0提问于2018-04-11得票数 1
回答已采纳
1回答
Android 2一次性
、、、
当我使用RXJava 1时，我总是跟踪我的订阅以执行活动onDestroy中的取消订阅。示例：
最近，我搬到了RXJava 2，然后我在网上寻找如何处理新的可处理设备的建议。
但我找不到任何东西，我所看到的每一个例子都被忽略了。
RXJava 2是否改变了它，现在我不再需要从一次性执行dispose方法了，或者我应该按照在RXJava 1天内实现的方式来实现？
浏览 2提问于2017-06-03得票数 2
回答已采纳
我有一个非常简单的RxJava示例
List<Integer> arrayIntegers = new ArrayList<>(Arrays.asList(1, 2, 3, 4, 5));
Observable.fromIterable(arrayIntegers).map(i -> {
Log.d("RxJava", "map i = " + i);
return i;
}).subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainT
浏览 4提问于2017-11-01得票数 0
回答已采纳
我在实现rxJava时遇到了问题，为了检查安卓系统上是否有互联网连接，我是这样做的：
在我的启动器活动中，我在onCreate中有以下内容：
AndroidObservable.bindActivity(this,
Observable.just(Utils.isActiveInternetConnection(Launcher.this)))
.subscribeOn(Schedulers.newThread())
.subscribe(new Action1<Boolean>() {
浏览 0提问于2014-12-29得票数 12
我有ServiceB，它依赖于服务A的响应，ServiceB被触发，但现在我遇到了错误NetworkOnMainThreadException @ onError。我是RxJava的新手，刚刚开始尝试示例。请帮帮忙，谢谢。
ServiceA
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.flatMap(new Function<ResponseA, Observable<ResponseB>>() {
浏览 0提问于2018-07-21得票数 0
1回答
我想使用rxjava并进行改造。这是我的改装建筑商：
Retrofit provideRetrofit(OkHttpClient okHttpClient) {
return new Retrofit.Builder()
.client(okHttpClient)
.baseUrl(UrlManager.API_HOST)
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2Cal
浏览 0提问于2018-03-25得票数 0
回答已采纳
我在玩rxJava/rxAndroid，有些非常基本的东西不像我期望的那样表现。我有一个可观察的和两个订户：
Observable<Integer> dataStream = Observable.just(1, 2, 3).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
Log.d(TAG, "subscribing sub1...");
dataStream.subscribe(v -> System.out.println("Subscriber #
浏览 2提问于2017-01-28得票数 21
回答已采纳
2回答
在处理RxJava状态更改(如方向变化)或异步平台事件(如推送通知事件)时，是否有一种处理订阅的优雅方法？
到目前为止，我一直在使用EventBus来处理这样的事情，如果可能的话，我希望能够完全转移到RxJava (不需要EventBus)，但是在处理这些场景时，EventBus体系结构似乎要好得多(只需要注册和注销)，特别是在处理安卓平台事件时。
单独使用RxJava，我们似乎仍然需要一种方法来将订阅持久化到片段/活动生命周期之外(无论是使用加载程序--、Retained片段、Application cache等等)，还有其他的方法吗？所有这些似乎都让人觉得需要额外的工作和处理。
浏览 6提问于2017-02-12得票数 1
我有两个不同对象的列表，称为使用Retrofit2。这两个列表工作正常，并返回所有元素OK。第二部分是两个对象都有一个属性"importe“(表示货币)，因此首先我需要将每个列表的对象相加为一个小计，然后将这两个列表的小计相加以得到总计(totalList1 + totalList2)，并在TextView中显示这个值。
我的问题是，由于我使用两个异步请求，所以无法对小计进行求和。我的代码可以找到。
我尝试使用retrofit2同步请求，但得到了一个错误：
android.os.NetworkOnMainThreadException
所以其他人建议我使用RxJava。有人能详
浏览 1提问于2017-07-25得票数 0
回答已采纳
1回答
我在阿波罗和Rxjava2中使用订阅，如下所示 Rx2Apollo.from(someApolloCall)
.observeOn(schedulerProvider.io())
.subscribeOn(schedulerProvider.ui())
.subscribe({
// on success
}, {
// on failure
}) 当网络正常时，一切工作正常，但是当失去连接时，订阅失败，不再重新连接？ 在类似的情况下，我应该如何重新连接，我一直在尝试使用rxjava操作retryWhen{}，但都是徒劳的！ 提前谢谢。
浏览 14提问于2018-12-19得票数 0
我正在尝试将Retrofit2与RxJava2结合使用，下面是Api：
public class App extends Application {
final String SERVER_ENDPOINT = "https://api.vk.com";
private Retrofit mRetrofit;
private static ImageService mImageService;
HttpLoggingInterceptor httpLoggingInterceptor;
@Override
public vo
浏览 1提问于2017-05-02得票数 2
回答已采纳
谁知道如何将Firebase与RxJava连接起来，这样当我从数据库加载所有数据时，它就会运行arrayAdapter.notifyDataSetChanged() ?？我正在考虑用onComplete()方法编写它，但它仍然在加载所有数据之前运行
Completable.fromCallable(new Callable<List<cards>>() {
@Override
public List<cards> call() throws Exception {
浏览 0提问于2020-06-05得票数 1
当我使用Observable.subscribe()时，通常返回Disposable。
但是Observable.subscribe(观察者)返回空。
所以我不能处置给Observable.subscribe(观察者)。
根据introtorx.com的说法，Observable.subscribe(Obeserver)返回Disposable。
为什么rx和rxjava不同？
++++++++++++++
我在Android Studio中使用compile 'io.reactivex.rxjava2:rxandroid:2.0.1'。
github.com/Reactive
浏览 5提问于2017-06-16得票数 6
1回答
下面的代码行运行网络调用来检索令牌：
service.token(initAuth()).blockingGet()
而令牌函数有以下定义：func token : Single<Token>
理论上，这个调用需要执行到主线程中，因为创建的用RxJava2CallAdapterFactory.create()重新安装，根据定义，RxJava2CallAdapterFactory.create()运行mainThread中的所有请求，因此我调用刷新/获取令牌需要触发NetworkOnMainThreadException whish。这些行为似乎是由于对blockingGet
浏览 0提问于2019-04-10得票数 0
回答已采纳
有针对RxJava的扩展。它提供了像ifThen这样的运算符。然而，使用它的优势并不明显。因为可以使用标准if-else块或三元运算符，这是可读性和通用性的。我检查了不同的函数式语言，没有发现类似的结构。它们都使用标准的if-else运算符。
此外，这样的扩展并不适用于所有的Rx语言，仅适用于RxJava 1.x。
问题是:在RxJava中使用ifThen运算符的目的是什么？与标准的if-else或三元运算符相比，它能提供哪些优势？
浏览 0提问于2016-12-09得票数 0
1回答
Rx异常处理失败
、、、
我正在使用带有改进的RxJava进行API调用，
通过使用RxJava方法(如、flatMap、和map )，我正在进行API调用，并在后台线程上的房间数据库中执行DB操作。
如果没有错误，我的实现是完美和工作良好的，但是当我在执行DB操作时得到一个错误或任何异常时，Application会因为以下Rx错误而崩溃。
E/AndroidRuntime: FATAL EXCEPTION: RxCachedThreadScheduler-1
The exception was not handled due to missing onError handler in the subscribe()
浏览 0提问于2018-12-05得票数 0
回答已采纳
我找不到关于RxJava Subscriber如何处理多个Subscription的清晰解释。(评论参考RxJava 1.x)
Subscriber有一个add( Subscription )方法，它“将Subscription添加到Subscriber的Subscription列表中”，没有进一步的解释。关于哪些Subscription可以参与的规则是什么？
有趣的是，Subscriber和Subscription都有一个unsubscribe()方法。据推测，subscriber.unsubscribe()将取消订阅整个Subscription列表，而subscription.unsubs
浏览 51提问于2017-12-25得票数 1
1回答
好吧，所以我是RxJava2新手(嗯，我也不认识RxJava )，我正在尝试用RxJava2和MVP结构开发一个安卓应用程序。
在该应用程序中，我对使用侦听器的库进行异步调用。我使用“标准”setListener / registerListener方法设置侦听器。
其中一种方法是返回值“实时”-> --我调用了库的start()方法，然后在每次修改列表时(当项有添加/删除时)，都会在侦听器上得到通知。
我并不真正理解如何使用RxJava实现这种行为，因为侦听器是在发射器/订阅者的定义中订阅的？我应该在哪里宣布听者？我应该在哪里取消订阅？我应该使用什么对象？
我使用启动开发，但可以切换到
浏览 2提问于2017-04-12得票数 0
回答已采纳
我在处理ConnectableFlowable和线程时遇到了问题：
我的更新服务返回一个ConnectableFlowable：
service.searchBeers(config.getKey(), name)
.map(Mappers.SEARCH_MAPPER).publish();
在我的Interactor类中，我订阅了它，将数据添加到Firebase数据库中，然后将ConnectableFlowable返回给演示者。我已经调用了传递IO线程的方法subscribeOn、unsubscribeOn和observeOn，因为Fireba
浏览 1提问于2017-10-30得票数 0
1回答
RxJava中有没有实现订阅状态的操作符？我想在一个可观察的订阅和取消订阅时得到通知。
我知道的唯一方法是创建一个PublishSubject，并使用doOnSubscribe和doOnUnsubscribe操作符向subject发送事件。
浏览 5提问于2016-07-18得票数 1
我是RxJava2的新手，我使用了defer、concat和create等其他方法。我正在努力寻找一种实现上述内容的方法。
具体的需要是，我有一个片段，显示和隐藏。这个片段有subscribers到EventBus事件。这些事件是由我一直在后台运行的服务触发的。
当碎片被隐藏时我不想失去他的排放。相反，我想以某种方式cache在隐藏时发出的排放物，然后在显示片段时释放它们。
是否有使用RxJava2 API的内置解决方案？
浏览 0提问于2017-01-31得票数 0
回答已采纳
我的build.gradle
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile "io.reactivex.rxjava2:rxjava:2.1.0"
在使用确切的库时，External Libraries在我的一个项目中显示了rxandroid-1.2.0 & rxandroid-2.0.1，而在另一个项目中只显示了后者。
1.2.0使用与rx.Observable兼容的rx.android.schedulers.Scheduler;，如下所示：
someRxObservable
.sub
浏览 12提问于2017-06-22得票数 4
回答已采纳
有一个例外，它反复出现在我的应用程序的Crashlytics(Fabric)上。我使用rxjava2进行http调用。
这就是crashlytics日志中的所有内容(如下所示)。会非常感谢你的帮助的/insights。
Fatal Exception: io.reactivex.exceptions.UndeliverableException: retrofit2.adapter.rxjava2.HttpException: HTTP 404
at io.reactivex.plugins.RxJavaPlugins.onError(RxJavaPlugins.java:349)
浏览 1提问于2017-09-19得票数 4
我正在使用以下观察值来执行常规任务。Observable在类首次加载到内存中时启动，然后定期执行我的代码。因为它是一个单一的可观察对象，所以从我的测试看，它肯定是一个假设，即代码永远不会第二次启动并并行处理，以防它运行的时间超过间隔。
private static Subscription subscription = Observable.timer(0, 1000, TimeUnit.MILLISECONDS)
.flatMap(new Func1<Long, Observable<String>>() {
@Override
浏览 1提问于2014-12-11得票数 0
我正在尝试在Room ORM中使用RxJava 2，但是当我尝试使用RxJava 2时，我的代码无法编译。
这是来自Contacts Dao的代码。
@Dao
public interface ContactsDao {
@Query("SELECT * FROM contact")
Flowable<List<Contact>> getAll();
@Insert(onConflict = REPLACE)
void insert(Contact contact);
}
我该如何解决这个问题呢？
编辑：
当我切换到subscribeWith
浏览 2提问于2017-06-23得票数 0
我尝试在RxJava中使用Retrofit2，但我是RxJava & Retrofit的新手。
我有一个api，比如：
@POST("donSomething")
Observable<RespData> doSomeThing(@Body ReqData reqData);
并且它可能会同时被多次调用。
如果同时多次调用doSomeThing，会产生多少个http请求？
如果我只想创建一个Http请求(使用RxJava)，我该怎么办？
浏览 2提问于2016-08-02得票数 1
2回答
我刚开始使用rxjava，然后就卡住了。也许我没有以正确的方式使用rxjava，但我需要在创建Observable之后向它添加项。所以我知道你只需要调用Observable.just("Some", "Items")，订阅者就会收到它们，但是如果我有一个异步任务，并且我需要在稍后任务完成时添加更多的项目，那该怎么办？我找不到像Observable.addItems("Some", "More", "Items")这样的东西
浏览 0提问于2015-03-07得票数 28
回答已采纳
1回答
我正在构建一个Android应用程序，并且是Rxjava的新手，我有一个初学者的问题:我如何在活动开始时订阅一个事件，并在活动停止时关闭订阅？
我搞不懂如何实现它。
浏览 1提问于2016-09-03得票数 2
回答已采纳
2回答
我们能否检测到一个类成员值是否正在使用RxJava进行更改？？假设在一个类中有一个变量var，那么当var的值使用RxJava发生变化时，我们可以得到通知吗？
浏览 6提问于2016-07-05得票数 9
回答已采纳
我在使用RxJava concat运算符时遇到了一个问题。我有两个观察点，第一个从服务器数据库发出结果，另一个从本地数据库发出结果，然后我连接：
// Uses a Realm in the UI thread
Observable<MyResult> remoteObservable = mRemoteDataSource.find(tId);
// Uses Retrofit
Observable<MyResult> localObservable = mLocalDataSource.find(tId);
Observable.concat(localObse
浏览 10提问于2016-09-03得票数 2
回答已采纳
1回答
在阅读了大量关于MVVM和RxJava的文章之后，我需要实现最简单的演示，以便在不使用DataBinding的情况下很好地理解这个想法。 但是我遇到了ViewModel如何通知带有数据列表的视图(活动)的问题 我的ViewModel包含fetchGitHub()，它以这种方式使用RxJava io.reactivex.Observable<List<Repo>> reposReturnedObservable = githubClient.reposForUser(user);
reposReturnedObservable
.sub
浏览 2提问于2019-01-25得票数 0
回答已采纳
我对RxJava还很陌生--从阅读开始学习，然后继续在上阅读，以了解RxJava2的不同之处。
然后，我尝试了部分中提到的第一个示例，不出所料地得到了MissingBackpressureException异常。然而，我再次尝试了相同的示例，但使用的是Observable (Kotlin代码)-
val valueProducer = PublishProcessor.create<Int>() // an ObservableSource
valueProducer
.observeOn(Schedulers.computation())
.map { Thr
浏览 3提问于2018-02-13得票数 0
1回答
我希望开始替换/使用RXJava2进行轮询，而不是使用观察者和侦听器。现在只有一个问题。我有一个可观察到的轮询，只有在至少一个订户被连接时才应该启动。如果连接了多个订阅服务器，则间隔应该相同。意思是:一个可观察的重复轮询过程在n秒钟内进行。如果可观察到的用户有1..*订阅者，它应该保持轮询n秒钟，并将结果通知所有订阅者。
对于侦听器和/或我的RXJava解决方案，我就是这样做的。
我的第一次尝试是创建一个单例类，它只创建一个PublishSubject。如果有人被订阅，它将获得onNext()中的数据。现在，我的轮询观察者在某个地方启动，并将数据推送到主题上。这不例外，因为它是
不良图案设
浏览 3提问于2017-04-06得票数 1
在使用RxJava进行假下载时，我试图强制抛出一个错误：
disposable.add(fakeRepo.downloadSomething()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{ a: String -> finished() },
{ b: Throwable? -> showError() }
浏览 0提问于2019-04-08得票数 0
回答已采纳
这是我在Kotlin的测试代码：
fun main() {
rxjava()
}
fun rxjava() {
val queuSubject = PublishSubject.create<String>()
queuSubject
.map { t ->
val a = t.toLong()
Thread.sleep(6000 / a)
println("map $a called ${Thread.currentThread().name} "
浏览 2提问于2021-07-02得票数 1
回答已采纳
当我使用sqlbrite时，在使用groupBy()之后不能使用rxjava函数toList()。下面是我的代码：
QueryObservable query = jetAnywhereDB.createQuery(Item.TABLE, "SELECT * FROM testTable");
query.flatMap(q -> {
return q.asRows(Item.MAPPER);
}).
groupBy(item -> {
return Character.toUpperCase(item.name.charAt(0));
}).
subscr
浏览 0提问于2015-10-20得票数 3
我遇到了一个使用RxJava2 (版本2.2.2)的问题。见下面的代码：
client.get("/iic-router/health").rxSend()
.doOnError(err -> { err.printStackTrace(); async.complete(); })
.doOnSuccess(v -> async.complete())
.subscribe();
如您所见，rxSend()方法返回Single的一个实例。当我运行这段代码并没有启动WebServer时，我得到了一个拒绝连接的错误(正如预期的那样)，但是我得到
浏览 0提问于2018-09-30得票数 4
1回答
订阅RxJava的第四个参数
、、、、
compositeDisposable.add(
myUseCase
.getData()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
{
println(it)
},
浏览 4提问于2022-02-26得票数 0
1回答
JSON
[
{
"countryName":"..."
},
{
"countryName":"..."
},
{
"countryName":"..."
} //etc... to 195 countries
]
接口
public interface RetrofitInterface {
@GET("GetCountries.php")
Single<List<Country
浏览 10提问于2021-12-30得票数 0
1回答
在rxjava中使用Place API时，我发现了一个问题。
当数据获取速度如此之快时，接口返回"status" : "OVER_QUERY_LIMIT"。我希望repeat以特定的延迟时间获取数据，以避免它。如何使用rxjava运算符执行此操作。
getCompositeDisposable().add(
getDataManager().getAtmsByBankName(nameSearch, location, radius, apiKey)
.subscribeOn(getSchedulerProvider().io())
.o
浏览 1提问于2018-08-08得票数 0
回答已采纳
7回答
不使用订阅的结果。
、、、、
我今天升级到了AndroidStudio3.1，它似乎增加了一些皮棉检查。其中之一是检查没有存储在变量中的一次性RxJava2 subscribe()调用。例如，从“我的房间”数据库中获取所有玩家的列表：
Single.just(db)
.subscribeOn(Schedulers.io())
.subscribe(db -> db.playerDao().getAll());
结果是一个大的黄色块，这个工具提示：
不使用subscribe的结果
像这样的一次性Rx电话的最佳实践是什么？我是否应该在完成时保持Dispos
浏览 8提问于2018-03-27得票数 153
回答已采纳
2回答
你好，我想问一下rxJava和房间的事。 这是我房间的Dao： @Query("SELECT * from `Order` WHERE id = :ID")
fun findOrderById(ID: Int): Flowable<Order> 下面是调用Dao的代码： mDB.orderDataDao().findOrderById(orderId)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
浏览 12提问于2019-05-03得票数 2
回答已采纳
我读过RxJava的文档。并尝试下面的演示:输出为d =d= false
我是否可以知道原因:为什么数据没有发射到Observer
RxJava版本：2.2.6
Observable.just("aa","bbb")
.observeOn(Schedulers.newThread())
.map(s -> {
System.out.println("s = [" + s + "]");
浏览 1提问于2020-06-01得票数 0
1回答
对于RxJava来说，我对接口回调(通过接口变量从内部层/代码模块调用)和RxJava有疑问。为了使它更清楚，快速的例子：
标准回调接口实现、接口、A类和B类
interface CustomCallback {
void onCallbackCalled(String str);
}
class ClassA {
private ClassB classB;
public ClassA() {
classB = new ClassB(new CustomCallback() {
@Override
pub
浏览 2提问于2017-05-06得票数 3
回答已采纳
我刚开始学习RxJava，发现它非常有用，但当我自己开始测试一些代码时，我发现它不能正常工作。
我写了一些这样的代码，但它不打印anything.The程序启动后立即停止。
public static void main(String[] args) {
Observable.just(1, 2, 3, 4)
.subscribeOn(Schedulers.newThread())
.observeOn(Schedulers.newThread())
.subscribe(new Action1<Integer>(
浏览 0提问于2017-10-30得票数 0
1回答
我是RxJava的新手，我的印象是，每个活动都会通知每个订阅者。因此，如果我们有N个订阅者和X个事件流，将调用N个订阅者中每个订阅者的onNext。但是当我运行以下代码时：
public static void main(String[] args) {
Observable<String> source = Observable.create(emitter -> {
emitter.onNext("Hello");
emitter.onNext("Foo");
浏览 19提问于2021-06-11得票数 0
回答已采纳
我对使用rxjava很陌生，我试图使用rxjava2在后台运行一个函数，但是这个方法没有被调用，下面给出了我使用的代码，让我知道它是否正确地在后台执行一个函数：
Observable.fromCallable<OrderItem>(Callable {
saveToDb(existingQty, newOty, product_id)
}).doOnSubscribe {
object : Observable<OrderItem>() {
override fun subscribeActual(emit
浏览 1提问于2017-11-03得票数 1
回答已采纳
我正在尝试使用RxJava 2以异步方式执行到S3的操作。
compile "io.reactivex.rxjava2:rxjava:2.2.2"
我有一个parts的Flowable。对于每个部分，我在TransferManager对象上调用一个方法，该方法立即返回一个Upload对象。
Upload::isDone方法javadoc如下所示：
/** * Returns whether or not the transfer is finished (i.e. completed successfully, * failed, or was cancel
浏览 0提问于2018-10-05得票数 1
QA团队执行的测试之一是疯狂地点击某个按钮，以确保只执行一个事件。是否可以使用RxJava来确保这种行为？我试着从RxJava上读到了RxJava，但我发现这真的很难理解。而且，我不知道如何从按钮的onClickListener发出一个事件--我想的一切最终都是创建一个新的观察者，而不是发出一个新的事件。
浏览 5提问于2017-06-28得票数 1
回答已采纳
在什么情况下需要在RxJava中使用RxJava？
像下面这样，它可以打印结果。
Observable.just(1, 2, 3, 4, 5)
.subscribe(line -> System.out.println(line));
如果更改为以下内容，它不会打印结果，但为什么会这样呢？
Observable.interval(500, TimeUnit.MILLISECONDS)
.subscribe(line -> System.out.println(line));
如果更改为使用blockingSubscribe，则可以再次
浏览 3提问于2020-06-10得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
