我收到一个对象(城市)，并希望在不同的线程中发送此数据(反映在移动屏幕上，并保存到DB this city)。}
public void unsubscribe() { }
所以这个方法，我想在UI线程上运行，repository.saveCityToDb(city);在后台线程上运行。
浏览 0提问于2016-09-14得票数 1
回答已采纳
我使用RxJava2 (单)对网络请求进行修改，当接收到响应时，添加对象包含的其他字段，有一个对象列表，我试图实现的是筛选出包含特定“id”的对象(在列表中)，当然，我希望它发生在后台线程上，然后在对象的列表过滤后发出响应超出作用域是否有一种方法可以在每个操作符中检测到它使用哪个线程？
浏览 4提问于2020-05-01得票数 0
emitter.isDisposed()) { emitter.onNext(i在最初的lambda中，我们创建一个新线程，然后在该线程上发出值。在第二个lambda中，我们有接收在第一个lambda代码中发出的值的代码。我注意到这两段代码都是在同一个线程上执行的。默认情况下，RxJava是否运
浏览 0提问于2021-01-03得票数 0
回答已采纳
我在Subject中创建了一个RxJava实例，并从多个线程调用它的onNext()：subject.onNext("A"); //thread A说：
注意不要
浏览 3提问于2015-08-05得票数 11
回答已采纳
这是我在Kotlin的测试代码： rxjava() val queuSubject = PublishSubject.create("$i") }}
我试图在不同的IO线程中运行map块和subscribe's onNext块。RxCachedThreadSchedule
浏览 2提问于2021-07-02得票数 1
回答已采纳
2回答
我对rxJava/Android很陌生，我的onError lambda有时在主线程上被调用，有时不被调用，尽管我使用.observeOn(AndroidSchedulers.mainThread())示例1:主线程上的onErroronError()-thread: RxComputationSch
浏览 3提问于2016-10-03得票数 9
回答已采纳
我是rxjava的新手。implementation "io.reactivex.rxjava2:rxjava:2.2.8"我和interval()一起工作，
我不知道如何在没有块UI线程的情况下在rxjava的onComplete() 中显示视图。或者从onComplete() onNext()调用，代
浏览 0提问于2020-08-19得票数 0
回答已采纳
我正在运行RxJava并创建一个使用onNext()方法生成数据的subject。我正在使用Spring。safeSource.subscribe(new Subscriber<AsyncRemoteRequest>() { public void onNext(myObj);}
在RxJava流上生成新数据的方式是@Autowire private SubjectObserver subjectObserver，然后<
浏览 3提问于2016-10-25得票数 1
回答已采纳
我正在尝试调用API并将数据添加到我的LiveData中，但是在我订阅之后，我在OnError中得到了MainThreadException。尝试了不同的调度程序，但没有成功。TAG, "onSubscribe in DistanceViewModel called. "); public void onNextRealCall.java:81)
at retrofit2.OkHttpCall.e
浏览 29提问于2020-12-15得票数 1
回答已采纳
它们可能从不同的线程发出这些通知，但必须在通知之间的关系之前正式发生。当它说“发生之前”时，是否意味着上一次onNext通知(例如，更改Observer.onNext()方法中的共享状态)所产生的所有影响在下一个onNext通知中将完全可见，就像在Java 中的保证之前发生的一样在阅读了SerializedObserver的源代码(RxJava版本3.0.11)后，我发现同步代码块中没有调用downstream.onNext(t)方法
浏览 5提问于2021-04-22得票数 0
回答已采纳
$2.onNext(OperatorOnBackpressureDrop.java:98) ~[rxjava-1.1.10.jar:1.1.10] at rx.subjects.PublishSubject$PublishSubjectState.onNext(PublishSu
浏览 3提问于2016-10-18得票数 1
回答已采纳
2回答
使用日志记录，我看到按钮的单击和MyService的操作都发生在主线程上，我想知道如何使服务在单独的后台线程中运行。
浏览 2提问于2016-02-29得票数 0
1回答
当我们在RxJava中使用观察者时，我想知道内部到底发生了什么，以及订阅者如何从观察者那里获得所有数据流。
提前感谢你们所有人。
浏览 4提问于2017-07-12得票数 0
我调用onNext 1,000,000次，从两个不同的线程计数。然后，我希望在onComplete能拿到200万英镑。public void onNext(T t) { ... actual.onNext(t);}
由于actual.onNext(t);是从同步块中调用的，我想actua
浏览 1提问于2017-01-25得票数 1
回答已采纳
在后台线程中我调用PublishSubject.onNext();，在主线程中通过subscribe(PublishSubject.filter(message -> message.getId() =我们使用'io.reactivex:rxjava:1.2.5' 'io.reactivex:rxandroid:1.2.1'
浏览 22提问于2017-02-16得票数 1
回答已采纳
我想运行一个新的线程，当用户点击按钮。在这个线程中，我在"i++“之后调用睡眠(2000)，并在TextView中返回字符串("Text”+ i)。super Void> subscriber) { i++;
subscriber.onNext(null
浏览 17提问于2020-12-02得票数 0
回答已采纳
在io.reactivex.rxjava3.internal.functions.Functions$OnErrorMissingConsumer.accept(Functions.java:718)$DoOnEachObserver.onNext(ObservableDoOnEach.java:97) io.reactivex.rxjava3.internal.operators.observable.ObservableFilter$FilterObserver.onNext(ObservableFi
浏览 9提问于2022-03-01得票数 1
回答已采纳
1回答
我正在学习RxJava，下面是本文： o.onNext("hello world");然后，我在文章之后更改了它，将"Object
浏览 3提问于2015-09-14得票数 2
回答已采纳
is a sync time consuming http connection subscriber.onNextsubscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
因此，正如您所看到的，getResult()方法是一个http调用我在io线程上订阅它，并在Android的主线程上观察。，而来自订阅
浏览 3提问于2016-02-23得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
实时音视频活动推荐
腾讯云开发者
