我调用了一个返回Flowable<List<Entity>>的方法。对于这个列表中的每个实体，我都想调用一个返回相关Single<AnotherEntity>的方法。然后，Entity和AnotherEntity应该合并到一个对象中，并且它们都应该在一个列表中返回。statsRepository.getGameLog(apiId)) stats -> { statsEntries.add(sta
浏览 8提问于2017-12-28得票数 0
回答已采纳
1回答
我想获取executeRequest()的所有结果，并将它们组合到Flowable数据流中，这样我就可以在perform()方法中返回此Flowable。所以最后，我希望我的方法返回Task执行的所有请求的结果。
executeRequest()返回Single，因为它只执行一个请求，并且可能只提供一个响应，或者根本不提供响应(在超时的情况下)。我尝试使用像merge()这样<em
浏览 0提问于2018-06-08得票数 1
我在科特林和RxJava一起工作。我有一个函数，transform(f: Foo): Single<Bar> 如何获取Foo的List，并对每个next执行transform，以获得Flowable<Bar>的结果，其中Flowable中的每个next都是调用transform的结果 基本上，我需要一个函数 fun getFlowable(foos: List<Foo&
浏览 8提问于2020-01-18得票数 0
回答已采纳
1回答
我需要从DB中获取数据。如果数据为空，则从服务器获取数据并将其插入数据库。这是我的密码 return dataDao.allDatas() .userDatas() .share();
浏览 6提问于2017-08-07得票数 1
回答已采纳
2回答
房间选择查询、获取或默认
、、、
interface UserDao { fun getUserByName(name: String): Flowable
浏览 0提问于2017-10-26得票数 2
回答已采纳
2回答
使用RxJava2 RxKotlin和Room，我需要查询数据库以进行开放式搜索。这意味着我要搜索一个包含值为false的名为closed的属性的搜索。一旦找到猎物，它需要将查询切换到该特定猎物。对于这些查询，我有两个方法：getHunt(huntId:String): Flowable<List我的想法是这样的
fun q
浏览 2提问于2017-10-02得票数 1
当我在由Flowable.merge()创建的两个可流(a1，a2)上使用Flowable.create()时，它只会发出a2。但是，当我在由b1 ()创建的两个可流动( b2，Flowable.interval)上合并时，它将像我所期望的那样发出b1和b2。那么，我的问题是，为什么这两种方法(创建和间隔)导致两种不同的结果流？(1, TimeUnit.SECONDS)
//
浏览 2提问于2018-01-08得票数 1
回答已采纳
3回答
是否有更好的方法来实现这一结果？it.status == Status.ERROR } if (isError) call.isEmpty() }
call.isEmpty()返回Flowable<Boolean>，但可以返回其他类似Single<Boolean>的内容。编辑：另一个问题，如果call.isEmpty
浏览 0提问于2018-09-02得票数 1
谁能用清晰的例子解释一下RxJava中可观察、可完成和单一之间的区别？
在哪种情况下，我们使用一个而不是其他的？
浏览 2提问于2017-03-13得票数 132
回答已采纳
我正在尝试使用RxJava与安卓异步更新我的视图。当用户从RecyclerView中的列表中单击电影时，如果存在，我希望首先向他展示数据库中的电影。然后，我想获取最新的信息，更新数据库和UI。我跳过了其他代码，只发布了相关的RxJava方法，这些方法正在获取数据，因为其他方法运行良好。
当我禁用下面代码的网络连接(因此远程返回错误)时，下面的代码根本不显示数据库中的数据。只有它报告错误。public Flow
浏览 1提问于2018-06-25得票数 0
回答已采纳
给定存储库类，它返回一个单独的：和返回浮点数的CompletableFuture：这里的问题是Single.fromFuture会阻塞，因此不能使
浏览 1提问于2019-12-02得票数 0
回答已采纳
如果DB是空的，我想首先在DB中获取数据，而不是调用服务器。但是当我用这种方式的时候，我没有任何反应。我一开始试着打电话给服务器，结果成功了。怎么了？这是我的密码： val subscription = })}
浏览 0提问于2019-01-21得票数 0
回答已采纳
1回答
我有一个活动，你可以看到一堆地方，根据过滤器和当前的视图的地图。因此，我将这两个源建模为Flowablesfun filtersFlowable():Flowable<FilterRequest>
其中边界发出地图视图端口的TopLeft和BottomRight角，而过滤器只发出用户应用的</e
浏览 0提问于2018-10-16得票数 0
回答已采纳
2回答
您好，我正在尝试使用rxjava和一个LiveData，它在我返回它之前使用Map进行了转换。然而，它说我需要从地图内部返回一些东西。我试着做return Single.just(pianoStorage.getAllFavItems())，它抱怨你不被允许返回一些东西？override fun getFavouriteItems() : Single<LiveData<MutableList<Items>>>{
//check if db has offers(sto
浏览 3提问于2018-02-19得票数 1
Observable<List<Campaign>> getCampaigns(List<Long> campaignIds);我读到网络请求应该使用"Flowable"，因为它是一个‘冷可观察’的背压管理。另一方面，我知道请求的结果将是成功(带有响应)或错误，因此我不知道是否应该使用Flowable或Single，甚至是Observable。此外，我还有这样的数据库访问：
public interface
浏览 2提问于2017-03-01得票数 41
回答已采纳
1回答
尝试使用可流动的，然后再做，最后使用RxJava3。public String post(Publisher<CompletedFileUpload> files) { return this.iProduct.post(requestBody);}
上面的代码有错误，但是下面的场景描述了我试图实现的目标
浏览 2提问于2021-03-07得票数 0
我有表联系人的数据库，我想检查是否有一些电话号码的联系人。@Query("SELECT * FROM contact WHERE phone_number = :number") }如果查询可以找到具有所需电话号码的联系人，则可以正常工作，但如果有<em
浏览 0提问于2017-07-06得票数 21
2回答
我必须压缩两个地方的结果:一个来自SharedPreferences作为一个Maybe，另一个来自Room持久性库(基本上是SQLite)作为一个Flowable。repository.getMaybe() .toSingle() .
浏览 2提问于2018-10-04得票数 0
回答已采纳
如果返回结果为真，我需要继续执行以下代码，否则我需要继续执行以下代码。我的问题是，我应该如何组合这两部分代码，其中第一部分是Flowable.just(isPayable())，应在计算线程中订阅，并根据返回值继续现有的解决方案。
浏览 27提问于2020-05-08得票数 1
我已经发布了它们分别工作的所有方法，但我面临第一个方法的问题，其中我使用了concatWith()两个流 .concatWithstoreModels) throws Exception { }
public Flowableresult.add(store.toStoreModel(StoreModel
浏览 4提问于2017-06-13得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
