1回答
我尝试实现下面提到的代码来完成任务，但是我得到了错误消息“没有一个函数可以用提供的参数调用” .map { 'Retrofit API call' })
我注意到mergeDelayError需要Iterable<?有没有其他方法可以用mergeDelayError实现这一点。若否，是否有其他选择？我选择这种方法的原因是为了处理在将列表的每一项发布到API时出现
浏览 8提问于2020-06-03得票数 0
我使用mergeDelayError让两个可观察到的对象发出它们的项，即使在发生任何错误之后。Observable.mergeDelayError(Observable.just(instance.getListFromSharedPrefs()), instance.getListFromApi} });
但是当修改api调用出现错误(即没有互联网连接)时，整个过程是在onError之后完成的，无法从
浏览 0提问于2015-12-30得票数 2
回答已采纳
line, so we batch them. Flux.mergeDelayError我的第二个想法是以某种方式使用takeUntil(Predicate<? super T> predicate)来决定何时停止从日志流量中提取元素。但是，如果我将无限大的日志流量与另一个确保周期性触发takeUntil的无限虚拟对象流合并，则可以使用takeUntil：
private static b
浏览 3提问于2021-02-03得票数 2
回答已采纳
3回答
Rx未按预期工作
、、、
我在RxAndroid中使用RxAndroid和Android应用程序。我使用将两个复古fit网络调用合并到一个可观察到的位置，如果发出一个项目，它将处理发出的项，如果其中一个发出项，则处理错误。Observable.mergeDelayError( .finallyDo(completeAction)
.subscribe(successActi
浏览 3提问于2015-08-21得票数 19
回答已采纳
我需要一些使用RxJava2 & Retrofit2实现并行异步调用的帮助。我的要求是；
1)我有多个保险公司(目前我只接受两个)，并且我需要使用该保险公司的名称发送多个并行请求。
浏览 0提问于2017-09-05得票数 0
2回答
根据从RequestA接收到的内容，我必须使用每个urls向另一个库发出请求(RequestB)。现在，每个RequestB都返回一个。有点像Observable.mergedelayerror(List<Single>)。我不能这样做，因为mergedelayerror期望iterable of ObservableSource。我知道我可以通过实现回调和使用一些丑陋的逻辑来实现这一点，但是我实际上是在通过使用RX提供的运算符来寻找解决方案。
浏览 6提问于2017-09-21得票数 6
回答已采纳
1回答
我有一个可观察的清单，我想知道他们什么时候都完成了。特别是，我想知道他们是否都完成了成功，或其中任何一个有一个错误。列表中的所有可观察性应在成功通知或错误通知执行之前完成。我不需要关于这些通知中的结果或错误的任何信息。期望的例子 .onSuccess(() -> {}) // only called if all completed successfully
.onError(() -> {}) // only calle
浏览 3提问于2015-02-27得票数 1
回答已采纳
return Observable.mergeDelayError( .map(something-> process(something)))根据文件：
mergeDelayError:将可观测到的发射到一个可观测范围内的可观察到的东西压平，使观察者能够接收所有源可观测到的所有成功发出的项目
浏览 0提问于2015-12-04得票数 0
回答已采纳
2回答
Completable#mergeDelayError(Iterable<?TimeUnit.SECONDS) }
Completable.mergeDelayError我知道Completable#mergeDelayError(Publisher<?
浏览 0提问于2018-04-09得票数 2
回答已采纳
1回答
使用rx寻找强有力的离线支持的建议。
Observable.mergeDelayError(
(如果步骤2或3失败)<e
浏览 4提问于2019-12-29得票数 1
回答已采纳
1回答
Single.mergeDelayError( Single.timer(3, TimeUnit.SECONDS) .reduceSingle<User> // Network request使用
浏览 17提问于2019-03-30得票数 1
回答已采纳
我知道如何使用RxJava连锁调用网络调用。但是通过链式调用，如果在调用第三次或第四次网络调用时出现错误，则不会执行其余的调用。因此，我希望即使前面的调用失败，其余的网络调用也能继续执行。
浏览 19提问于2019-03-21得票数 0
回答已采纳
3回答
我希望组合/合并多个可观测值，当它们完成时，执行一个finally函数。merge操作符似乎并行执行每个订阅，这正是我所需要的，但是如果其中任何一个抛出错误，执行就会停止。我应该换个接线员吗？var source2 = Rx.Observable.throw(new Error('woops'));
var source3 = Rx.Observable
浏览 2提问于2017-08-17得票数 6
回答已采纳
2回答
} }}1)在observable内部进行异步，生成一个新线程，或者使用基于回调的文件读取2)使用调度器在I/O线程上进行工作，
同样，对于DB，我必须创建我自己的observable来包装数据库Api，并且有一个带有回调的同步和异步版本。其次，我如何在一个链中使用这些观察值来并行读取这些文件，然后将每个文件的内容存储在数据库中。我希望在所有引用数据的整个过程完成时接收一个onCompleted事件。
浏览 1提问于2016-05-06得票数 2
1回答
我有一个创建和合并两个Observable<T>的方法。 .delay(2, TimeUnit.SECONDS);
Observable<String> observable2 = Observable.create(new Observable.OnSubscribe<Stri
浏览 3提问于2016-01-28得票数 2
回答已采纳
我有一个Android Kotlin代码，其中包含一个可完成项列表，这些可完成项与mergeDelayError()合并为一个更大的可完成项，它有一个超时。smallCompletable1, )
.mergeDelayError
浏览 38提问于2019-11-06得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
