腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
RxJava
Flowable
中
的
延迟
元素
、
、
在@ProjectReactor publisher Flux中有一个非常直观
的
名为delayElements
的
运算符,可以在每个发出
的
元素
之间引入
延迟
。比方说,下面的cod每秒发出一个
元素
。
中
完成相同
的
行为,我必须进行一些仪式。final List<Integer> data = List.of(1, 2, 3); .tak
浏览 43
提问于2020-07-25
得票数 0
回答已采纳
1
回答
测试
RxJava
: AdvanceTime不能在简单
的
延迟
流
中
工作
、
、
我有一个非常简单
的
函数,它以给定
的
延迟
提交一个值: .subscribeOn(computationScheduler)我试着像这样测试它在computationScheduler
中
的
时间提前感谢您<e
浏览 2
提问于2020-05-13
得票数 2
回答已采纳
2
回答
(Scala +
RxJava
3) Flowables.orderedMerge NoSuchMethodError
、
、
在Ammonite
中
,我执行以下代码...试着做两个可流动
的
orderedMerge, `io.circe::circe-generic:0.13.0`.core.
Flowable
.subscribe(
Flowable
.java:15750) io.reactivex.
rxjava
3.cor
浏览 10
提问于2020-05-21
得票数 1
回答已采纳
1
回答
如何根据流
中
的
元素
动态划分连续
的
RXJava
流?
、
、
最简单
的
示例是如下所示
的
字符串流: ["3", "a", "b", "c", "1", "a", "2", "a", "b"] 是数字
的
数字描述了它
的
组应该包含多少
元素
。非常重要
的
是,流是连续
的
,所以我们不能只等待下一个数字来拆分流。据我所知,
RXJava
2
中</em
浏览 21
提问于2019-04-06
得票数 2
回答已采纳
2
回答
在
Rxjava
中使用可流时无法处理错误
、
Flowable
.just(getSize()) .observeOn(AndroidSchedulers.mainThread()) .onErrorResumeNext(
Flowable
.just
浏览 3
提问于2018-10-03
得票数 2
回答已采纳
1
回答
rx 2 Schedulers.io() steel从mainThread调用方法
、
、
、
、
我试图用Rx方式使用room从数据库
中
检索数据。我就是这么做
的
super.onStart()fun getAllBooks() :
Flowable
<List<Book>> { update
浏览 3
提问于2017-11-13
得票数 0
回答已采纳
1
回答
RxJava
1.x
中
的
默认反压策略是什么?
、
、
我正在将一个Android Studio项目从使用
RxJava
1.x切换到
RxJava
2.x,并试图尽可能少地更改功能。该项目使用了Observables,在
RxJava
1.x
中
是背压
的
。在
RxJava
2.x
中
,Observable不再是背压
的
,但
Flowable
是,所以我将Observable
的
用法转换为
Flowable
的
用法。但是,
Flowable
.c
浏览 0
提问于2017-02-03
得票数 3
1
回答
如何签入当前
元素
是最后一个
元素
的
操作符?
、
、
上下文:要处理
Flowable
<Item>,我需要先处理第一个item,然后根据这一点,要么将所有项累加到单个项(reduce)
中
,要么对每个项应用一个简单
的
映射,而不累加(map)。我认为需要操作符知道当前
元素
是最后一个
元素
的
一种方法。是否有这样
的
运算符知道当前
元素
是否是最后一个
元素
?我不能使用缓冲区,因为即使在不应该进行积累
的
情况下,它也总是获取2个
元素
。addData(item.g
浏览 2
提问于2022-05-08
得票数 2
回答已采纳
1
回答
io.reactivex.exceptions.CompositeException$CompositeExceptionCausalChain:因果链对CompositeException
的
有序接收
、
、
、
、
micronaut
中
的
自定义全局异常} @Singleton return HttpResponse.ok(0);} .doOnError(throwable -
浏览 6
提问于2021-07-13
得票数 1
回答已采纳
1
回答
如何根据属性以不同
的
方式继续Rx链?
、
、
我有一个方法,基于可流动
的
数据值,我需要以不同
的
方式继续接收链。我
的
意思是,如果数据对象
的
isOnline属性为true,那么我需要调用scan(initial,selector),但是如果它是false,那么我需要调用scan(选择器) @NotNullpublic
Flowable
<Data> initialCall(
浏览 17
提问于2020-12-18
得票数 0
回答已采纳
1
回答
使用
RxJava
retryWhen算子时Kotlin型失配
、
、
我正在尝试创建可观察
的
,这将retryWhen时,网络连接将建立。我创造了一个主题:我就是这样用
的
: retrySubject.onNext(null) } } va
浏览 1
提问于2018-06-21
得票数 4
1
回答
只在必要时生成新值(Flux/
Flowable
.generate & sample)
、
、
是否只有在真正需要新
的
价值时才能产生新
的
价值? 在下面的示例
中
,即使每秒只使用一个值,也会始终生成新值。我知道我可以用interval代替,但我希望消费者控制利率。编辑:,我也对
RxJava
的
解决方案感兴趣。
浏览 0
提问于2018-01-28
得票数 0
1
回答
以
RxJava
Observable<>为数据类型
的
Android提供编译错误
、
、
对于下面的代码,我得到了以下错误:@Dao
Flowable
<List<Friends>> getAllFriends(); Observable<List<Friends>> getAllFriendsExample
浏览 0
提问于2018-06-16
得票数 0
回答已采纳
2
回答
如何跳过第一个项目,如果在
RxJava
上
的
某个时间段获得第二个项目
、
我需要在收到事件(表示任何数据项
rxJava
)后
的
X秒内执行一些操作。但如果在X秒结束之前获得另一个事件,则需要在X秒内再次执行计时器重置和操作。 换句话说,我们有用户可以与之交互
的
UI
元素
。在用户对此UI
元素
保持不活动X秒后,我们需要执行一些操作。简单
的
解决方案可能如下所示: Disposable disp; final
Flowable
<Boolean>
flowable
= ma
浏览 31
提问于2020-04-17
得票数 0
回答已采纳
1
回答
如何异步地将
Flowable
<ListenableFuture<List<T>>>压平为
Flowable
<T>?
我使用
的
是
RxJava
2.0.0-RC4。我试过这个:
Flowable
<ListenableFuture<List<Integer>>> futures = ...
Flowable<
浏览 4
提问于2016-10-25
得票数 1
回答已采纳
1
回答
如何使用核心库中提供
的
操作符递归地生成可流动
的
RxJava
?
、
下面这个简单
的
程序最终会挂起。// Kotlinimport io.reactivex.
rxjava
3.core.Singleimport java.util.concurrent.TimeUnit.SECONDS) numbers(1, 1_000
浏览 0
提问于2020-04-11
得票数 1
1
回答
如何对
Flowable
执行操作
、
、
你好,我是
RxJava
的
新手,我有一个接收
Flowable
<Item> f2
的
类,我需要从它获取值,而不需要更改任何数据(将值保存到本地缓存)。然后将其与其他
Flowable
f1连接,并将其发送到更高级别的类。是否可以从f2
中
只发出一次值 另外,我如何对来自
Flowable
f1
的
所有项目执行操作,但在n个项目之后从f1创建新
的
Flowable
f2。
浏览 21
提问于2019-05-28
得票数 0
回答已采纳
1
回答
是否可以懒洋洋地在
Flowable
.generate()中生成项?
、
我有一个数据库,可以在
RxJava
链工作
的
过程中进行更新。
RxJava
链如下所示: .subscribeOn(Schedulers.single(链处于处理排放
的
中间时,数据库可以被更新。因此,
Flowable
.generate()应该一次请求一项,直到onNext()使用者完成,并且只在查询下一项之后。是否有可能在调用
Flowable
.
浏览 0
提问于2018-10-17
得票数 0
回答已采纳
1
回答
用
rxjava
检测文件文本更改
、
、
、
我想实现一些检测任何文件更改
的
代码(txt、doc、pdf等)。用
RXJava
触发一些任务。有可能吗?有什么建议吗?提前谢谢。
浏览 1
提问于2018-11-06
得票数 1
回答已采纳
1
回答
RxJava
2将两个流程压缩为一个
、
、
我很难找到任何
RxJava
2
的
例子,把两个流量计拉链成一个。<Integer> source =
Flowable
.fromArray(ints);
Flowable
<Integer> anothersource =
Flowable
.fromArrayBiFunction<
Flowable
<Integer>,
Flowable
<Integer>,
Flowable
<Integer&g
浏览 0
提问于2017-10-09
得票数 5
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RxJava 2.2.0 发布,Rx 的 Java 实现
Chrome将可以延迟加载网页中iframe元素 提升网页加载速度
浅析 Python 中的延迟绑定问题
PHP去除数组中的空值元素
物联网感知层中的不可替代元素!
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券