这是一个两个线程在100ms左右循环的例子。奇怪的是，循环的方式不是while(true)等，而是在执行后使用onNext将项添加到可观察值的方式。 用kotlin编写的代码如下所示。runBlocking { delay(100) } _ps_2_thread_loop.onNextrunBlocking { delay(100)
浏览 29提问于2020-07-03得票数 0
1回答
我是RxJava的新手，我的印象是，每个活动都会通知每个订阅者。因此，如果我们有N个订阅者和X个事件流，将调用N个订阅者中每个订阅者的onNext。但是当我运行以下代码时： Observable<String> source = Observable.create("Bar");
emitter.onNext<
浏览 19提问于2021-06-11得票数 0
回答已采纳
我正在使用具有两个观察值的RxJava CombineLatest。我的问题是，如果其中一个观察值以onError结尾，组合onNext会被调用吗？文档显示了当两个可观察对象都正确地发出项时的愉快场景，但我找不到在错误情况下会发生什么。|-onError-| Observable1|-| CombineLatest -是否会调用onNext？
浏览 0提问于2019-02-25得票数 2
2回答
RxJava2观察者不支持在onNext函数中省略onNext。 at io.reactivex.internal.operators.observable.ObservableSubscribeOn$SubscribeOnObserver.<
浏览 10提问于2017-03-06得票数 2
回答已采纳
2回答
在RxJava中，背压并不是真正的背压，而只是忽略了一些元素。RxJava不能影响元素发射，所以开发者需要自己实现它。想到的最简单的方法是使用一些计数器，在发射时递增，在完成时递减。s.isUnsubscribed()) { s.onNext(Math.random());(100);
浏览 2提问于2016-11-12得票数 2
1回答
我试图在RxJava的onPostExecute()上实现一个可观察到的/订阅者，但我不知道如何建立连接。我在Observable方法中创建了onPostExecute。@Override // create the observableObservable<String> myObservable = Observabl
浏览 1提问于2015-05-20得票数 2
回答已采纳
2回答
我需要从JSon提要中加载数据(多达22,000条记录)，并将它们存储在我的安卓设备上(以SQLite格式)。我可以看出如何不择手段地完成它，但是我真的很想用RxJava来完成它，但不确定如何做。
谢谢
浏览 3提问于2015-05-01得票数 4
回答已采纳
我有多个热的可观察物，它们可能会也可能不会发射粒子。因此，我希望合并这些可观察对象，如果它们中的任何一个发出结果，则处理结果，但如果其他可观察对象发出一个结果，则应将它们一起处理。例如：observable2 = PublishSubject<>()
observable1.onNext(2)
o
浏览 8提问于2018-01-11得票数 0
回答已采纳
/:1.2.0] at rx.observers.SerializedSubscriber.onNext(SerializedSubscriber.java:94) ~[rxjava-1.2.0/:1.2.0]
at rx.Observable.unsafeSu
浏览 0提问于2018-05-28得票数 0
回答已采纳
我正在尝试使用rxjava和rxjava 2进行webservie调用。我正在探索使用RxJava2的两种不同的方法。问题是，当我使用Observable时，我得到了响应，但是它没有使用Flowable。当使用Flowable时，日志不会被打印，我试着调试它，但是它不会在onNext、onComplete或onError中运行。只有onSubscribe被执行。1)使用可观察的返回类型
new WebRequestManager().
浏览 0提问于2018-04-30得票数 1
回答已采纳
有一个例外，它反复出现在我的应用程序的Crashlytics(Fabric)上。我使用rxjava2进行http调用。 at retrofit2.adapter.rxjava2.BodyObservable$BodyObserver.onNex
浏览 1提问于2017-09-19得票数 4
我使用RxAndroid在我的应用程序中执行计时器任务。使用Observable.interval()执行此操作。一切都很正常，但我需要停止活动的onDestroy()中的计时器。这是我正在使用的代码： .flatMap(n -> mObservableNewChatonError- " + e.getMessage());
}
浏览 1提问于2018-01-30得票数 5
我正在学习RxJava异步订阅是如何工作的。但有些问题让我困惑。emitter.isDisposed()) { new Thread(() -> emitter.onNext("value_" + finalI但是，当我在订阅前添加睡眠时，最后一条消息value_9将不会被打印，如下所示：
@Test public void testCreateAsync() throws InterruptedExceptionThread.sle
浏览 1提问于2017-06-23得票数 1
回答已采纳
我正在更新一些旧的android应用程序代码，不知道如何将RxJava/RxAndroid1.0中的代码转换为RxJava/RxAndroid2.0。我试图转换的代码负责获取信号强度指示器，并每秒钟用它的值更新图表。我在SIGABORT中成功破解的东西根本不起作用，几秒钟后，应用程序就用RxJava崩溃了。我不知道我错过了什么？我的RxJava 1代码：
rx.Observer myObserve
浏览 4提问于2017-05-21得票数 0
回答已采纳
我有一个rx.Observable，它将任务的进度发送给onNext()。onNext()的排放有时会如此之快，以致于Observer无法跟上，从而导致。我只想通过缓冲来自Observable的最新排放来处理背压。
浏览 2提问于2015-08-04得票数 6
回答已采纳
Int -> }) subject1.onNext(1) subject1.onNext(0) disposable.dispose()}1 0subject1 <
浏览 0提问于2019-09-03得票数 2
1回答
我使用RXJava调用一个开销很大的递归函数。大多数情况下，它运行得非常快，但有时会产生过长的耗时 mObserver = getSudokuPuzzleObserver();observable.subscribeOn(Schedulers.newThread())
浏览 0提问于2018-01-04得票数 1
1回答
.* def start() {
Observable.create({ s -> s.onNext(1); s.onCompleted()}).subscribe({println it});
container.deployVerticle("groovy({ s -> s.onNext(1); s.onCompleted()})
浏览 2提问于2014-04-11得票数 0
我查看了RxJava关于的文档，没有办法跳过错误。我想知道在操作RuntimeException (如map)时是否有任何方法可以轻松跳过任何Observable情况是一样的：
List<Integer> ints = Lists.newArrayList(1, 2, 0 , 3 ,
浏览 0提问于2015-02-08得票数 10
我在使用下面提到的库调用API时遇到了一个问题。:rxandroid:2.0.1'提供改装实例的代码@Singleton
RxJava2CallAdapterFactory的情况下调用API时没有问题。有没有人能告诉我哪里出了问题，或者为什么我会遇到这样的错误？at com.jakewharton.retrofit2.adapte
浏览 4提问于2017-01-24得票数 4
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
