我假设在很多情况下，需要根据值列表调用外部RESTful服务。List<Integer> products = Arrays.asList(1, 2, 3); 现在，对于这些productId中的每一个，我想并行调用一个外部端点。products){ } 如何将其转换为List<Completabl
浏览 13提问于2020-07-15得票数 1
回答已采纳
我有一个对象列表，这些对象应该依次传递给API，并需要在所有调用完成后进行最终回调。代码结构看起来像public class RestAPIManager {
}
//Class from which the above <
浏览 7提问于2017-02-03得票数 1
回答已采纳
我使用带有两个函数的外部API，一个函数返回Maybe，另一个函数返回Completable (参见下面的代码)。我希望函数'saveUser()‘返回一个可完成的，这样我就可以使用doOnSuccess()和doOnError来检查它了。但目前我的代码没有编译。private Maybe<DataSnapshot> getMaybe(String key) {
// external API that returns a may
浏览 0提问于2018-10-13得票数 3
我现在的安卓应用程序使用Retrofit和RxJava来编排我的网络呼叫。依次调用GET(1)、GET(2)、GET(3)当POST(1)和POST(2)都完成OK时，调用GET(4)。我的代码类
浏览 1提问于2018-08-10得票数 10
回答已采纳
我正在使用RxJava进行网络调用，在每次请求之前，我都需要检查网络。目前，对于每个请求，我都是这样做的。Log.d(TAG, "onComplete: "); });
private CompletableCompletable.complete() : Completable.error(new Throwable("Network Error
浏览 0提问于2017-10-11得票数 0
1回答
我想调用一个API api1并将API返回的输出传递给第二个API api2。第一个API是一个get请求，第二个API是一个POST请求。因此，api1返回一个Single<String>，api2返回一个Completable。这些函数如下所示：public Single<String> getToken() {
浏览 0提问于2018-12-05得票数 3
回答已采纳
对于Retrofit调用，我使用Rx，对于Room，我使用Coroutine。由于RX和Coroutine的混合，我无法进行一些顺序调用。如上所述，步骤必须是顺序。下面是我正在使用的一些代码 report : Report,
images: List<
浏览 3提问于2020-05-13得票数 1
回答已采纳
我已经看过如何使用TestSubscriber测试可观察的，但我不知道如何测试Completable.doOnSuccess回调。具体而言，这种方法： this.authToken = authTokenreturn Completable.fromSingle<User>(api
浏览 2提问于2018-09-03得票数 1
回答已采纳
4回答
我使用的是realm 3.4和rx java2。我想要做的是在将数据插入到realm中后返回一个可完成的。public Completable insertSamplesRx(final List<Sample> sampleList) { @Override Completable.c
浏览 0提问于2017-07-08得票数 1
2回答
我正在查询一个API，它为我提供了要下载的文件列表(如下所示)。然后，我继续下载这些文件，同时重新查询API中任何在初始调用中可能遗漏的内容。Completable#mergeDelayError(Iterable<?我知道Completable#mergeDelayError(Publisher<?extends CompletableSource> sources, int maxConcurrency)，但不知道如何将List<Completable
浏览 0提问于2018-04-09得票数 2
回答已采纳
1回答
我有两个异步方法，它们在一次操作时被调用。每个方法都可以成功完成，也可以检索时出错。在出错的情况下，我不得不再次重试调用每个方法，延迟了2秒。意思是，我应该同时调用这两个方法，不管其中一个方法的结果如何。在错误回调中，我想知道哪个方法出错，或者两个方法都出错。
看起来我应该使用Completable来做这件事，但我在Rx上绝对是新手。Completable completable1 = Completable.create(metho
浏览 0提问于2018-06-25得票数 0
结果:无法解决方法“合并( io.reactivex.rxjava3.core.Completable，io.reactivex.rxjava3.core.Completable，io.reactivex.rxjava3.core.Completable)”
我目前正在尝试设置一个注册用户的流。这里的想法是在某个数据库中创建一个用户，检索响应数据，并调用不同的API。每当我尝试使用可完成的合并方法进行此操作时，它就会抛出上述错误。例如，我们有一个为用户(createU
浏览 2提问于2020-10-20得票数 0
回答已采纳
我试图将Firestore方法包装到CompletableEmitter中，以便在成功/完成时返回Completable.complete()，在失败时返回Completable.error()。下面的代码没有封装在一个可完成的代码中：public static Completable updateDocument
浏览 0提问于2019-05-22得票数 3
回答已采纳
我在一个安卓应用程序中使用RxJava 1 (1.3.6)来控制应用程序启动流。为了控制启动流，我尝试使用如下的Completable.concat方法：public Completable startup(final String configUrl) {()));我看到的是，initializeConfig方法被调用，在Completable完成之前，initializeFirstPart和initializeSecondPart方法都被调用</e
浏览 0提问于2018-02-19得票数 0
回答已采纳
1回答
条件链单链和完全链
、、、、
我的Rx调用的总体工作流程应该按照以下方式工作(不管当前的Rx代码如何)：
}
}
.flatMapCompletable { api.up
浏览 1提问于2018-03-17得票数 3
回答已采纳
1回答
基本上，我想进行一个api调用，然后将信息保存在数据库中，以便下次启动应用程序时，它会从db加载数据。因此，为了实现这一点，我为数据库中的每个插入创建了一个可完成的，然后每当它完成时在UI中通知我。我的api调用：它返回一个用户列表和一个消息列表。我在数据库中插入：
fun insertUsers(users: List<User>) = Completable</em
浏览 3提问于2018-10-10得票数 1
回答已采纳
3回答
我对新的RxJava Sources感到非常兴奋，比如：Single、Maybe、Completable，它们使您的接口类更加简洁，并防止在创建“源代码”过程中出现许多错误(例如忘记调用onComplete让我们假设我们有两个源-- api和cache，我们希望将它们组合在一起： Single<Integer> loadFromNetwork(); ).firstOrError();
因此，我看不出有任何
浏览 6提问于2017-07-26得票数 14
回答已采纳
1回答
= nextCompletable.startWith(completable) completable .subscribeOn(AndroidSchedulers.mainThread())我使用以下代码来检测异步可完成项：
private fun getAsyncCompletables(): Comple
浏览 0提问于2018-11-29得票数 1
2回答
我正在尝试RxJava，我发现了一个小问题，我不知道如何处理。我在我的应用程序中使用的是google地图API，所以当创建包含地图的片段时，我必须调用这将在准备使用map时调用一个回调方法。mMapReadySignal = Completable.fromEmitter(objectEmitter -> {
OnMapReadyCallback
浏览 1提问于2017-01-14得票数 1
我有一个示例API请求，它返回用户监视列表的列表。当用户加载监视列表屏幕时，我希望实现以下流
) fun saveUserWatchlist(repositories: List<Repository>): Completable> {
return api.getWatchlist(userI
浏览 2提问于2017-11-18得票数 4
回答已采纳
云服务器
ICP备案
云直播
对象存储
即时通信 IM
腾讯云开发者
