腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
ZipWith
的
Rxjava
间隔
不能按
预期
工作
、
、
someObservableTwo(), { t1, t2 -> } //success //error }) 这段代码
的
主要目标是每
浏览 20
提问于2020-11-05
得票数 0
1
回答
Kotlin通配符法
、
我在
RxJava
中
使用
RxJava
函数时遇到了一些问题。 val retryFunc = Func1<Observable<out Throwable>, Observable,则in关键字使
使
浏览 1
提问于2015-12-30
得票数 2
回答已采纳
1
回答
何时
使用
zip()而不是
zipWith
()
RxJava
、
在
RxJava
中
使用
zip()和
zipWith
(进行成对组合是否存在语义上
的
差异?在静态压缩和.
zipWith
之间
的
选择是纯粹
的
风格吗?
浏览 0
提问于2017-08-09
得票数 16
3
回答
如何在并行处理
的
RxJava
组中引入延迟?
、
、
我
的
用例是对流进行分组,开始并行地处理一些组,并且在每个组中,将每个项
的
处理延迟到一个常数
间隔
。我似乎无法正确地理解组内
的
延迟,因为它们不是定期发出
的
,而是几乎瞬间发出
的
。下面是我
使用
RxJava
2.0.5
的
测试代码:public class GroupsAndDelays {
浏览 5
提问于2017-02-04
得票数 1
2
回答
如何在
RxJava
中
使用
TestScheduler
我应该如何
使用
RxJava
的
TestScheduler?我来自.NET背景,但
RxJava
中
的
TestScheduler似乎与.NET rx中
的
测试调度程序
的
工作
方式不同。下面是我想要测试
的
示例代码contactsRepository.find(index) .buffer(MAX_CO
浏览 3
提问于2014-11-02
得票数 20
回答已采纳
2
回答
无法理解Lambda ->算子
、
、
我从网络上复制了一个代码,它
使用
Lambda操作符。下面是代码。, (time, item) -> item) 我正在努力学习
rxJava
,却无法了解这个lambda函数是如何
工作
的
,这就是这些时间和项变量是如何
工作
的
?<R>
zipWith
(Iterable<U> other, BiFunction<?obj是字符串
的
数组.So,有人能告诉我这些参数是如何与
使用
Lambda运算符
的</e
浏览 1
提问于2018-08-07
得票数 1
回答已采纳
1
回答
如何
使用
RxJava
将每个列表项与异步操作结果合并?
、
我
的
新闻有List<News>列表.我必须为每个新闻发出异步请求,以获取新闻图像列表(来自API)。我试着用
RxJava
做它,但我做不到( 我认为
使用
该Observable.fromIterable(newsList),然后
使用
zipWith
(imagesListRequestObservalbe,News, News(with images)),然后
使用
toList(),但是它是如何在代码中生成
的
--我不知道。请告诉我如何用
RxJava
解
浏览 2
提问于2017-06-21
得票数 0
1
回答
可以在`
zipWith
`运算符内部订阅吗?
、
我
使用
的
是
RxJava
2,并且有一个类似下面这样
的
可流动函数 .doOnNext() .onErrorReturnItem() } .flatMap() 在
zipWith
操作符中,我
的
条件根据结果返回不同
的
列表。实际上,
浏览 8
提问于2017-02-27
得票数 1
2
回答
在
RxJava
2中延迟重试/重复
、
我正在升级到
rxjava
2,我们有代码来轮询来自服务器
的
数据,当出现网络问题时,代码句柄可以延迟重试。但是,当我试图迁移到
rxjava
2时,代码就停止
工作
了。下面是
Rxjava
1
的
代码,
的
工作
非常完美的,基本上遵循这个和这个 .retryWhen(new Func1<Observable<? extends Throwable>, Observable<?Observable<Long> call(Observabl
浏览 3
提问于2017-08-27
得票数 0
回答已采纳
2
回答
RxJava
重试N次
RxJava
2 .error(new IllegalStateException()) .
zipWith
为什么它不像它那样
工作
,我应该如何调试它?
浏览 3
提问于2017-05-09
得票数 0
回答已采纳
3
回答
如何在RxSwift中延迟
的
情况下逐个从Collection发出项
、
我想从anyCollection中创建一个可观察到
的
,在延迟之后逐个释放每个元素。另外,onNext我想对项目(模型)执行一些更新。//喂养所有狗,一个接一个,
间隔
5秒。seconds // timelapse -> 12 seconds} 我试图像"
zipWith
“一样
浏览 2
提问于2017-11-24
得票数 3
回答已采纳
1
回答
安卓
RxJava
2 retryWhen
使用
情况未编译
、
、
、
然而,尝试在Kotlin中将重试添加到
RxJava
2 retrofit2调用中,无法找出正确
的
语法。我做了一些研究,发现我需要
使用
类似于模式
的
retryWhen (用于重试3次):api .subscribeOn(Schedulers.io>
zipWith
(p0: ((Subscriber<in (???..???)>!) -> Unit)!, p1: ((Throwable, ???) -> ?
浏览 1
提问于2018-09-04
得票数 0
1
回答
即使与延迟一起
使用
,反应性
zipWith
也不懒惰
、
、
我有这段带有项目反应堆框架
的
代码,但这也适用于
rxjava
1,只是测试了它(猜测
rxjava
2 ),并且我找不到为什么
zipWith
()操作符评估其参数可流动
的
原因,即使事先对事件进行了过滤并
使用
了defervoid main(String[] args) { .filter(s -> s > 4) .
zipWith
浏览 2
提问于2018-10-28
得票数 0
回答已采纳
1
回答
如何对
RxJava
retryWhen进行单元测试
、
、
、
我试图在
RxJava
可完成
的
情况下
使用
指数退避,当我尝试它时,代码
工作
得很好。因此,我们试图添加一个单元测试来覆盖它,但我不确定我们如何在这里测试retryWhen部件。.retryWhen { errors: Flowable<Throwable> -> .
zipWith
(还没有找到很多关于测试
的
信息来确保retryWhen
的
工作
) 提亚
浏览 0
提问于2018-12-21
得票数 0
1
回答
不能在纯JS中组合确认()和if( setInterval() )
我有以下简单
的
if(confirm())条件 agreed_function(); cancel_function下面是我
的
代码,其中只有if(confirm())有效,但
间隔
不起作用 cancel_function(); },
浏览 0
提问于2019-09-14
得票数 3
1
回答
为什么我
的
RxObservable从不开火?
、
、
我有一个硬编码
的
可观察序列,它是用
间隔
序列压缩
的
。其意图是对每一个要素都引入一个延迟。13 Observable.just(1, 2, 3) .
zipWith
(Observable.interval(1000L, TimeUnit.MILLISECONDS
浏览 5
提问于2017-06-26
得票数 1
回答已采纳
1
回答
在UI线程上运行findallAsync().asFlowable()之后
的
运算符
、
、
我面临一个问题,
rxjava
操作符正在UI线程中运行。我
使用
findAllAsync()异步获取对象,
使用
asFlowable()
使用
rxjava
操作符处理它们。getId()); // Print 1 }但是在
rxjava
示例中,它们
使用
的
是observeOn(Android
浏览 2
提问于2017-11-02
得票数 0
回答已采纳
2
回答
RX java io.reactivex.
rxjava
3.android.schedulers.AndroidSchedulers无法执行
、
、
实现'io.reactivex.
rxjava
3:rxandroid:3.0.0‘实现'io.reactivex.
rxjava
3:
rxjava
:3.0.0’ val标签:String= RXKotlinDemoClassMethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;;或者它
的<
浏览 132
提问于2020-04-14
得票数 1
回答已采纳
1
回答
RxJava
2:
使用
可流动
的
zipWith
我试图让下面的代码正常
工作
,但有些地方出了问题,下面是一个片段:Flowable.fromIterable(cache)Flowable.fromIterable(m_cache) // return
浏览 0
提问于2018-11-29
得票数 0
回答已采纳
1
回答
在
zipWith
中
使用
范围也会在应用拉链函数之前发出范围序列中
的
所有项目
、
、
问题是关于
RxJava
2
的
。 it.onError(RuntimeException("always fails")) .retryWhen { it.
zipWith</
浏览 1
提问于2017-08-25
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何正确地实现重试(Retry)
一款基于RxJava2+Retrofit2实现简单易用的网络请求框架
Kotlin,RxJava与RxAndroid混合开发
重新理解响应式编程
微软 Win11 KB5022303、KB5022287 累积性更新发布
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券