首先，我以前从未使用过RxJava。我必须实现一个开发工具包，这是使用AndroidRx或RxJava的所有用例和提供的例子。我有以下从后端返回数据的方法
override suspend fun getSomeData(token: String): Outcome<String, DataError> {现在我正在尝试实现如下所示的方法，以使用RxJava与SDK进行交互，它将在flatmap中调用上面的方法(基于示例)。这有可能吗？我已经尝试了几个小时，但没有任何成功。如果我修改上面的方法以返回<
浏览 17提问于2021-02-27得票数 0
1回答
您好，我有一个rxjava平面映射，我想在其中调用一个协程用例onStandUseCase，这是一个api调用。最初的用例也是基于rxjava的，它曾经返回Observable<GenericResponse>，现在我将用法改为基于协程，它只返回GenericResponse。如何修改平面地图以与协程用例配合使用 subscriptio
浏览 44提问于2021-01-08得票数 4
嗨，我有一些用例，这是用Java写的，使用rxJava。我把它们转换成kotlin文件，而不是rxJava，我把它们变成了挂起函数的例程。在我的rxJava代码中，我从用例中进行了一个api调用，它返回结果，但同时onNext它做了一些事情，onError它做了一些事情。 @PerApp
@
浏览 18提问于2021-01-13得票数 1
1回答
我正在尝试从Kotlin中的服务器获取一些数据，我希望在这些数据上做一些进一步的处理，比如将其显示给用户。但是执行并不是等待/阻塞返回结果，而是继续执行。在此之后，syncWithServer()将在函数startingSync()中的单独线程上启动一个网络请求。但实际执行结果如下所示： 1->6->2->3->4.请注意，android logcats中没有登录5和7。我相信执行线程不是在等待网络请求结果返回，因此没
浏览 31提问于2020-10-13得票数 0
回答已采纳
RxJava Kotlin平面映射不返回分隔字符串中的分隔对象。相反，它返回列表。"521934/2342/FOXTROT").subscribe{Log.d(TAG, "$it")}[521934, 2342, FOXTROT]
但是书(Thomas : Learning
浏览 3提问于2017-09-27得票数 3
回答已采纳
2回答
所以我有两个片段: 1)带有条形码扫描仪的片段2)带有简单文本视图的片段有人能以正确的方式指导我如何正确地实现它吗？
浏览 0提问于2020-04-11得票数 0
我需要帮助，以便只有当我点击google API后收到某些结果时，代码行才会等待该方法返回，然后在下一行代码中使用该结果。
浏览 24提问于2019-11-28得票数 1
我还在网站和Kotlin应用程序中使用Firestore。在网站上，我可以通过以下方式将查询结果保存为变体： const addStudentManu = async($this) => { const getUserId = userId.docs.map(doc=>doc.id);
} 我如何在kotlin
浏览 23提问于2021-06-23得票数 0
在我用Kotlin编写的应用程序中，我试图避免RxJava链的终端状态，因此我发现将Observable<T>转换为Observable<Result<T>> ( Result是密封类)是正确的。(val data: T) : Result<T>()假设我可以观察到这个网络请求Success(true) }
浏览 5提问于2017-06-15得票数 14
回答已采纳
我使用RxJava链接异步操作，我想在下游传递一些变量： .from(modifications)
.flatmap( (data1) -> { return op1(
浏览 8提问于2015-01-27得票数 90
回答已采纳
1回答
带改进的协程线程安全
、、、
关于使用协程发起网络请求的线程安全性，我仍然有一点麻烦。假设我们有以下用例，有一个我们获得的用户列表，对于每个用户，我将做一些特定的检查，这必须通过对API的网络请求来运行，给我一些关于这个用户的信息。因此，我所做的是为每个用户启动请求，并使用单个resultHandler对象，该对象会将结果添加到列表中，并检查结果列表的长度是否等于用户列表的长度，如果是，那么所有userChecks都完成了，我知道我可以对结果执行一些操作，这些结果需要一起返
浏览 15提问于2021-10-21得票数 0
回答已采纳
我正在尝试使用Kotlin Flows为我的API调用实现先缓存后网络的策略。Flow<Data> Timber.i("Response Received")这里的问题是只有当getDataFromServer返回时才会调用在这个变体中，"Response Received"只打印一次，即在getDataFromServer()返回之后。suspending function returning Flow&
浏览 0提问于2020-02-13得票数 10
许多示例将LiveData从存储库返回到ViewModel}
但是，如果我们只返回字符串并将返回的数据设置到ViewModel的LiveData中，会有什么不同吗？因此，我们可以跳过这一步，从Call对象中获取值，在ViewModel中返回它，然后在ViewModel中将值设置到LiveData中
浏览 2提问于2019-09-27得票数 2
谷歌最近宣布了新的Page3库，Kotlin-first库，支持协程和Flow...etc。
我尝试过他们提供的，但似乎还没有任何对测试的支持，我也查看了。
浏览 47提问于2020-06-19得票数 18
我在一个setOnClickListener块中首先有一个方法调用，它从我用来启动实况流的API中获取一些值，这对该方法调用来说很关键，在块内完成任何其他操作之前，为了获得正确的结果，因为第一行方法调用之后的所有其他事情都依赖于它}我需要让myButton.setOnClickListener块等待
currentViewModel.checkStream()，以便以下行正常工作(给出正确的结果
浏览 0提问于2019-04-22得票数 1
4回答
我正在努力探索安卓上的Retrofit+OkHttp。下面是我在网上找到的一些代码：.setClient(new OkClient(okHttpClient)).build();
浏览 1提问于2014-01-08得票数 42
回答已采纳
我想知道CompletableFuture，Future和Observable RxJava之间的区别。我所知道的都是异步的但是CompletableFuture给出了回调方法例如:如果客户端需要进行多个服务调用，并且当我们使用Futures (Java)时，Future.get()将被执行，sequentially...would想知道如何在RxJava中更好。非常想知道RxJava
浏览 6提问于2016-02-11得票数 258
回答已采纳
首先，这是一个非常具体的案例，故意以错误的方式将异步调用改造成一个非常同步的代码库，该代码库有数千行长，时间目前无法进行更改以“正确地执行”。它伤害了我生命中的每一根纤维，但现实和理想往往并不协调。我知道这很糟糕。function doSomething() {
data = d;
// block here and return data when the callback is f
浏览 6提问于2012-02-03得票数 266
回答已采纳
2回答
我对RxJava非常陌生，每当我遇到需要将返回数据从一个可观察对象传递到“subscribe”调用为止的情况--我很难理解如何在没有任何补丁的情况下以“反应式”的方式完成这项工作……Observable);Observable<GameObject> obs3 = func4();
我想发出obs1和obs2，得到它们的结果，然后发出obs3，然后是obs4，然后用subscribe结束链，同时可以访问obs1
浏览 0提问于2016-01-19得票数 1
云服务器
ICP备案
腾讯会议
云直播
实时音视频
腾讯云开发者
