腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5571)
视频
沙龙
1
回答
RxJava
将
发射
收集到
列表
、
、
、
Observable<User> .toList() 对其应用flatMap函数后,如何收集所有用户
列表
并一次性发送?
浏览 8
提问于2019-06-13
得票数 1
2
回答
如何创建可观察到的无限项流
我有一个
发射
器,它能无限地
发射
物品。如何
将
发射
器发出的项目流转换为
RxJava
2中可观察的(或同类的)项流。
浏览 0
提问于2019-08-16
得票数 0
回答已采纳
2
回答
如何
将
RxJava
Observable<Map<String,List<Integer>>的
发射
拆分成多个
发射
?
、
、
、
我正在尝试
将
一个
RxJava
.Observable<Map<String, List<Integer>>的排放拆分为多个
RxJava
.Observable<Map<String, List<Integer每个
发射
都应该包括原始
列表
的一个分区,所有这些都是按原始顺序排列的。可以保证每个
列表
具有相同的大小和(list.size() % partitionSize) == 0。
浏览 1
提问于2020-09-28
得票数 1
1
回答
“拆分”/“生成”操作按顺序进行?
、
我试图在
RxJava
中找到一个适合下一个序列操作的操作:实际的用途是,我有一个可观察的,包含一个项目的
列表
,我正试图转换为可观察的
发射
扁平的项目从
列表
如下所示:我似乎找不到合适的
RxJava
操作来执行这样的操作--有flatMap(),它与我想要的完全相反,但没有
浏览 1
提问于2014-09-04
得票数 1
回答已采纳
1
回答
将
Object[]数组转换为String[]数组
RxJava
、
、
、
我正在尝试使用
RxJava
将对象
列表
中的一些属性
收集到
数组中。我已经编写了代码,但现在不能正确地转换返回类型。
浏览 3
提问于2016-10-26
得票数 0
回答已采纳
1
回答
上一次调用的每个项目的Rx Java和Retrofit api调用
、
、
、
、
DiscussionPostRoot> getCommentsInPost(@Path("commentId") String commentId) DiscussionPostRoot有一些字段和对象
列表
,对于这个
列表
中的每个对象,我想调用相同的API调用,但使用不同的值。
浏览 9
提问于2017-07-14
得票数 0
1
回答
是什么取代了
rxjava
2中的AsyncEmitter?
我正在尝试
将
一个反应式项目从
rxjava
1迁移到版本2。我通过指定一个BackpressureMode,使用一个AsyncEmitter连接到一个现有的提要。然而,我没有在
rxjava
2中找到一种类似的方法来做到这一点。是什么取代了
rxjava
2中的AsyncEmitter?我看到有许多
发射
器实现,但没有一个接受BackPressureStrategy。
浏览 27
提问于2017-01-30
得票数 2
2
回答
在
RxJava
2中创建自定义操作符?
我很难找到如何使用
RxJava
2制作自定义操作符的示例。 使用Observable.create,然后从可观察的源对其进行flatMap处理。我可以让它起作用,但感觉不太好。在OnSubscribe中,我实例化了一个
将
发射
器传递给的对象,该对象处理和管理可观察/
发射
器(因为它并不简单,我希望尽可能封装所有内容)。对于
RxJava
2,我找不到任何这样的例子。我不得不调试我自己的示例,以确保我对上游和下游的理解是正确的。因为我找不到
RxJava
2的任何示例或文档,我有点担
浏览 3
提问于2017-01-24
得票数 8
回答已采纳
2
回答
不同尺寸的
RxJava
标记阵列
、
String[] array3 = new String{"@", "#"};{"1", "a", "@", "2", "b", "#", "3", "c", "4"} 用
RxJava
浏览 1
提问于2016-04-08
得票数 1
回答已采纳
1
回答
RxJava
2:在一段时间后发出
收集到
的项目
列表
、
、
、
我有一个可观察的,当它被添加到db时,它是在听数据库和
发射
项目。当我订阅这个可观察到的内容时,它会一个一个地在db中快速释放已经存储的项。我的问题是,我是否可以创建可观察的方法,将以特定间隔(例如,100 millis)发出的项
收集到
列表
中,并发出(或在某些函数中返回,如doOnNext)整个
列表
和单独的项(如果发出的间隔较大)?
浏览 1
提问于2017-09-04
得票数 1
回答已采纳
2
回答
如何使用
RxJava
对来自异步源的数据进行分组
、
、
、
、
我对
RxJava
了解不多,但我的理解是toList不能工作,因为源观察值永远不会完整。你知道如何收集产品代码的数据,并在任何数据发生变化时发出
列表
吗?:)
浏览 25
提问于2021-06-18
得票数 0
回答已采纳
1
回答
使用
RxJava
的嵌套网络请求
、
、
、
、
我对
RxJava
非常陌生。我在
将
嵌套的异步操作转换为
RxJava
结构时遇到了问题。我如何构造我的
RxJava
observable,以便能够获取一个条目
列表
(类型A,每个条目都有一个唯一的id),并根据获取的
列表
,以id (第一个
列表
中的每个类型A的条目)作为参数,获取单个条目(类型B),并且仅在
将
接收到的条目(类型B)添加到
列表
之后?
浏览 1
提问于2017-09-08
得票数 1
1
回答
RxJava
将
发出的值
收集到
数组
、
、
如何从可观测到数组收集发出的值?Observable.just(1,2,3,4,5,6)[1,2,3,4,5,6]
浏览 3
提问于2019-06-11
得票数 2
回答已采纳
1
回答
确保即使没有订阅者也能观察到执行
我有一个可观察的缓存并重用它们。它们通常都使用某种类型的缓存(主要是replay(1).refCount()),并且我确保底层计算只在这种情况下完成一次。目前,我只能这样做:o.connect() // make sure this hot observable always is connected and processes it's input return o // this one is cac
浏览 0
提问于2018-09-21
得票数 0
2
回答
如何
将
AsyncTask和AsyncTaskLoader替换为它们的Rx等价物?
、
、
、
,, --所有这些谈论的主要是
RxJava
,而不是AsyncTask或AsyncTaskLoader的替代品。 class MainActivity : AppCompatActivity() { override fun
浏览 2
提问于2017-10-23
得票数 1
2
回答
长链中的
rxjava
StackOverflowError异常
、
、
、
、
我在一些设备(例如Android4.1)上与许多运营商( doOnNext、doOnError、switchIfEmpty、onErrorResumeNext、flatMap )构建了非常长的
rxjava
$CallOnSubscribe.call (RxJavaCallAdapterFactory.java:152)retrofit2.adapter.<e
浏览 4
提问于2017-02-21
得票数 1
回答已采纳
1
回答
在添加项目时,RX java发出带有延迟的
列表
项目
、
、
、
我有一个正在从外部来源更新的
列表
。我想要的是一个观察物,它
发射
单个项目与固定的延迟,因为更多的项目添加到
列表
。我想用
RXJava
做这件事。
浏览 6
提问于2017-12-17
得票数 0
2
回答
RxJava
手动发出项
、
、
我是
RxJava
世界的新手。我几天前就开始尝试做一些非常具体的事情。protected List<T> commands = new ArrayList<>(); Observ
浏览 4
提问于2017-03-04
得票数 2
1
回答
RxJava
与长时间运行的侦听器
、
、
好吧,所以我是
RxJava
2新手(嗯,我也不认识
RxJava
),我正在尝试用
RxJava
2和MVP结构开发一个安卓应用程序。 在该应用程序中,我对使用侦听器的库进行异步调用。其中一种方法是返回值“实时”-> --我调用了库的start()方法,然后在每次修改
列表
时(当项有添加/删除时),都会在侦听器上得到通知。我并不真正理解如何使用
RxJava
实现这种行为,因为侦听器是在
发射
器/订阅者的定义中订阅的?我应该在哪里宣布听者?我应该在哪里取消订阅?我应该使用什么对
浏览 2
提问于2017-04-12
得票数 0
回答已采纳
1
回答
无法实现BufferUntil
RxJava
、
尝试为BufferUntil实现Observable (即,每当满足某些条件时,缓冲区元素和发出缓冲
列表
)界定:尝试为
RxJava
实现完全相同的public <T extends Object> Ob
浏览 5
提问于2017-02-16
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Android 响应式编程 RxJava2 完全解析
RxJava系列七
Kotlin,RxJava与RxAndroid混合开发
RxJava系列五
DIATEST测量数据采集分析系统SPC分析IBR无线传输模块发射接收器
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券