2回答
假设我有一个可流动的，某个视图是订阅的，它正在监听更改。我想添加一个自定义方法，该方法仅基于flowable的第一次发出，但也会保留侦听更改的其他方法。最好的方法是什么？我有一个天真的方法是复制可流动的，并将其转换为单个或可完成的，以获得结果，但它似乎是多余的。 谢谢。
浏览 7提问于2019-02-23得票数 0
1回答
我想根据上游排放的数量来分支逻辑。准确地说，我想：我正在为如何处理这个问题而挠头，我想出了一些可行的方法通过打破阀门，我的意思是终止使用最初关闭的valve的控制PublisherFor‘只有一个发射逻辑’。使用ambArray在没有排放或第二次排放的情况下
浏览 53提问于2018-12-19得票数 0
回答已采纳
1回答
我有两个可流动的(一个是给我VelocityNed项目的，另一个是我写来消费第一个项目的)；问题是我不知道怎么做第二个，因为我仍然对RxJava不太确定。我的流动代码： Flowable<Float> flowable= Flowable.create(emitter->{
浏览 6提问于2021-12-14得票数 0
回答已采纳
val flowable01 = Flowable.fromArray(listOf( Value(epoch = 10,string ="apple"), val flowable02= Flowable.fromArray(listOf(
浏览 20提问于2021-05-08得票数 0
我有一个数据库，可以在RxJava链工作的过程中进行更新。RxJava链如下所示： .subscribeOn(Schedulers.single(concatMap(/*Mapping*/) .subscribe(/*Consumers*/)
当RxJava链处于处理排放
浏览 0提问于2018-10-17得票数 0
回答已采纳
描述了Observable和Flowable之间的区别。然而，与Observable相比，Flowable更多地是用它缺乏的特性来描述的。提到的Observable只有一个显著的特点：
使用Observable通常比Flowable具有更低的开销。但即便如此，这似乎也与以下建议相矛盾:对于少量的元素而言，Observable更可取，如果任务太重，则更有可能导致OutOfMemoryError。这似乎表明Fl
浏览 4提问于2017-04-27得票数 7
回答已采纳
1回答
我正在努力解决如何从数据层引发网络错误到视图层。public Flowable<List<DEvent>> getAll() { .getting DEvents - " + Log.getStackTraceString(throwable)); }));
我怎么能发出这
浏览 2提问于2017-09-05得票数 1
回答已采纳
我的用例是对流进行分组，开始并行地处理一些组，并且在每个组中，将每个项的处理延迟到一个常数间隔。我似乎无法正确地理解组内的延迟，因为它们不是定期发出的，而是几乎瞬间发出的。下面是我使用RxJava 2.0.5的测试代码：public class GroupsAndDelays {
Function<Integer, Flowable<Integer, 90], 23:[8, 28, 48, 68, 88], 24:[
浏览 5提问于2017-02-04得票数 1
2回答
房间选择查询、获取或默认
、、、
在SQL中，有一个方法mapToOneOrDefault。房间里有类似的东西吗？interface UserDao { fun getUserByName(name: String): Flowable<User>如果getUserByName("John")中没有John，则流不会返回任何DataBase。
浏览 0提问于2017-10-26得票数 2
回答已采纳
1回答
微背压
、、
我们正在寻找限制使用Micronaut2.0.1公开的HTTP端点所接受的并发连接数量的最佳方法。端点接受图像文件，将它们写入磁盘并创建缩略图。由于请求太多，我们内存不足。对Micronaut和Netty来说，有什么可靠的方法来实现这样的背压吗？
浏览 2提问于2020-10-14得票数 1
1回答
我的存储库中有一个getPlaces方法： returnflatMapPublisher { it -> }该方法从api中收集结果，然后将结果保存在数据库中，并以Flowable<
浏览 1提问于2018-06-12得票数 5
回答已采纳
1回答
我试图将Flowable<T>中的值映射到Flowable<T2>中，但是如果Flowable<T>中缺少某个值(或者如果Flowable<T2>中缺少转换的值)，则应该抛出一个异常。例如：Flowable<EndType> res
浏览 2提问于2022-07-06得票数 0
谷歌的安卓体系结构组件教程有一个部分解释了如何抽象通过网络获取数据的逻辑。在它中，他们创建一个名为NetworkBoundResource的抽象类，使用LiveData创建一个反应性流，作为所有反应性网络请求的基础。LiveData的形式从Android db获取数据，并将其添加到作为源LiveData的“结果”中
( c)在dbSource LiveData的第一次发射中，从“结果”中删除dbSo
浏览 0提问于2018-04-15得票数 4
回答已采纳
当在Schedulers.computation上订阅javarx2 Flowable时，如果任务超过线程池大小，会发生什么？我如何了解它的行为？Flowable .flatMap(key ->Flowable
浏览 4提问于2018-06-26得票数 0
1回答
尝试使用可流动的，然后再做，最后使用RxJava3。public String post(Publisher<CompletedFileUpload> files) { return this.iProduct.post(requestBody);}
上面的代码有错误，但是下面的场景描述了我试图实现的目标
浏览 2提问于2021-03-07得票数 0
2回答
我有一个网络客户端，它能够从中断中恢复，但需要最后一条消息，这样做时，有重试。fun requestOrResume(last: Message?= null): Flowable<Message> = val connection = if (last !问题：如你所见，我需要最后一条收到的信息来准备简历。我如何跟踪它，以便当有重试时，它是可用的
浏览 1提问于2017-10-30得票数 0
回答已采纳
我用Java编写了以下代码： .flatMap(Flowable::just);Flowable.just(1,2,3)虽然Java代码编译得很好，但是Kotlin编译器说："Error:(47，30) Kotlin:一个类型参数需要用于类Flowable: Publisher in io.reactivex“
然而，
浏览 12提问于2017-08-13得票数 3
这是在编写这样的代码时应该发生的事情，还是需要在框架中解决的问题？ 该代码已使用rxjava-2.2.19进行了测试。来源可以在here上找到。示例 下面的代码基于我们用来完成某种带有中断条件的循环的代码(参见flowable = flowable.switchIfEmpty(third(s)))。显然，这种方法并不能很好地工作。<String> flowable = Flowable.empty();
浏览 13提问于2020-08-20得票数 0
回答已采纳
我已经考虑过这个问题了，但我不知道如何解决.许多答案都提到servlet配置错误，但没有说明如何修复它和更改什么。我的catalina日志文件如下所示： at org.apache.catalina.u
浏览 7提问于2019-04-08得票数 0
现在，我正试图了解如何将RxJava2库与Retrofit2结合使用。我的Api服务： Observable<String> getObservable(@Url String url);
Flowable<String> getFlowable(@Url String url);和主要活动：
mApiService.getObservable("httpspublic void onC
浏览 2提问于2017-09-12得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
