腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
RxJava
的doOnSubscribe是在emit之后而不是之前调用的
、
、
我有一个
RxJava
的链,看起来像这样: .
andThen
(fetchData()) .
andThen
(...) /* some action */问题是在最后一个
andThen
()之后调用doOnSubscribe
浏览 8
提问于2020-02-25
得票数 0
1
回答
官方(和丑陋的)顺序组成的替代方案
、
在vertx指南中,用于链接异步调用的顺序组成如下所示:Future<Void> startFuture = Future.future(); fs.createFile("/foo", fut1.completer()); // When the file is created (fut1), execute this: Future<Void
浏览 1
提问于2018-05-02
得票数 0
1
回答
在
RXJava
2中
andThen
()是如何工作的?
尝试学习
RXJava
2的Completable.
andThen
()。fun main(args: Array<String>) { .
andThen
(showTime())} private
浏览 4
提问于2018-07-25
得票数 0
回答已采纳
4
回答
在
RxJava
和Kotlin中,大括号和普通括号有什么区别
、
、
我不明白在使用
RxJava
时,花括号和Kotlin中的普通括号之间的真正区别。例如,我有如下代码,其工作原理与预期相同: .
andThen
(anotherMethodThatReturnsACompletable但下列各点不起作用: .
andThen
{ anotherMethodThatReturnsACompletable() }注意链的
andThen
()部分与大括
浏览 14
提问于2017-08-17
得票数 25
回答已采纳
1
回答
RxJava
2如何将单链链接到可完成的对象,以便在可完成的情况下订阅
、
String, password: String): Completable { .
andThen
浏览 0
提问于2018-06-01
得票数 4
回答已采纳
2
回答
RxJava
2 |使用.
andThen
()链接嵌套的可完成表
public Completable checkAndProcessFile(InputStream file, ...) {} return writeFile(file).
andThen
processFile(file, ...) { return Completable.fromCallabl
浏览 0
提问于2018-08-07
得票数 0
回答已采纳
2
回答
如何将Vert.x Future.compose()转换为等效的
RxJava
2实现
、
createHttpServer) // Consumes RouterFactory我想知道如何在
RxJava
2Completable所做的事情,但将值从一个传递到另一个:this.initConfigRetriever() // Returns a JsonObject .
andThen
(this::asyncLoadDbSchema) /
浏览 0
提问于2018-04-21
得票数 0
回答已采纳
1
回答
RxJava
Completabe
andThen
测试
我有以下
RxJava
2 Kotlin代码: .
andThen
(SingleSource<Int> { Single.just这个想法与这篇博客文章中的想法类似: .
andThen
(performOtherOperation
浏览 4
提问于2017-08-15
得票数 10
回答已采纳
1
回答
在飞行模式后引发HiveMQ异常,会话已过期,因为连接已关闭
、
、
、
) .
andThen
浏览 27
提问于2019-09-19
得票数 0
回答已采纳
2
回答
如何在Rx / Reactive中以编程方式在Completable.complete()中添加Completable.complete()
、
、
、
、
如何使
andThen
()操作符链在可完成的位置上?例如,原始代码如下: .
andThen
(processdata("01")) .
andThen
(processdata("03"))
浏览 7
提问于2022-10-13
得票数 1
1
回答
RxJava
2-未来可完成的
andThen
?
、
、
我有这样的代码: return getFirstCompletable().
andThen
(getSecondCompletable问题(我认为)是,当我调用getSecondCompletable()并将结果传递给
andThen
()时,第二个未来就被创建并开始运行,尽管第二个可完成的还没有被订阅,第一个未来还没有完成。我正在将这段代码从
RxJava
1迁移到
RxJava
2,最初该代码使用FlatMap连续运行两个Single<
浏览 2
提问于2017-09-08
得票数 1
回答已采纳
1
回答
RxJava
/Kotlin可观察方法调用链-如何终止?
、
、
、
我正在学习
RxJava
,我想从注释中创建Observable,然后在其上应用转换,比如将其映射到实体模型并进行保存。如何从这个仅用于启动Completable的Observable中打开
RxJava
。每个editNote()方法返回一个Completable。.map { noteEntity -> .
andThen
flatMapCompletable { noteEntity -&
浏览 1
提问于2018-12-08
得票数 3
回答已采纳
4
回答
RxJava
返回单,执行可完成后
、
、
由于single.
andThen
(),下面的代码没有编译。这些操作需要按照这个顺序执行。result") }val together = single.
andThen
浏览 0
提问于2018-02-02
得票数 17
回答已采纳
1
回答
RxJava
1和2对Completable.
andThen
()具有不同的结果
、
我创建了下面的类来演示de problem: //
RxJava
2 .subscribeOn(io.reactivex.schedulers.Schedulers.computation()) .
andThen
CompositeSubscription().add(completableRxJava1()
浏览 0
提问于2019-06-12
得票数 0
回答已采纳
1
回答
使用
RxJava
进行循环
、
Flowable.just(
rxjava
.list1).concatMap(new Function<ArrayList<Data>, Publisher<Data>>() {
浏览 1
提问于2017-11-24
得票数 0
1
回答
如果用户离开屏幕,则不执行
RxJava
2操作
我通过
RxJava
2执行了一个remove操作,它会刷新本地缓存,如下所示: return from(placesApi.deleteExperience(experienceId, placeId)) .
andThen
(问题是,有时这个删除操作需要足够长的时间让用户离开屏幕,然后
andThen
操作永远不会执行,因为没有订阅者,因此屏幕上的信息不再是最
浏览 0
提问于2018-07-19
得票数 7
1
回答
在我插入新值后执行
、
、
、
我正在学习
Rxjava
2,我正在尝试把房间图书馆和
Rxjava
2集成起来。问题是:我有一个填充的表,每次登录应用程序时,我都需要删除这个表,然后在数据库中插入一个新内容。
浏览 0
提问于2018-11-16
得票数 8
回答已采纳
1
回答
用可完全
RxJava
2算子调用序列的
andThen
阶
、
、
我正在尝试从
RxJava
1迁移到
RxJava
2。我要将以前有Observable<Void>的所有代码部分替换为Compleatable。但是,我遇到了一个流调用顺序问题。然而,
andthen
()操作符的工作方式似乎有点不同。下面是一个简化问题本身的示例代码。我也找不到任何其他操作符来代替
andthen
()。任何人都不知道如何在
RxJava
2中修改它,这样它的行为就会相同吗?在处理流之前,我依赖于一个可完成的作业(比如刷新会话令牌、更新db、首选项等)--在使用
RxJava
1
浏览 1
提问于2017-04-01
得票数 6
回答已采纳
1
回答
为什么Completable.
andThen
不工作?
、
、
我正在开发一个安卓应用程序使用Kotlin,
RxJava
(RxKotlin)。fun getAndSave() { .
andThen
{getAndSave() { retrofitApi.getA() .
andThen
浏览 2
提问于2020-09-21
得票数 0
1
回答
如何有条件地启动
RxJava
链,使其可完成为可流动的链?
、
、
我在getThings()中有下面的代码,它可以工作,但根据我看到的示例,它不像是正确使用
RxJava
。downloadThings() Completable.complete()} 我对
RxJava
缺乏理解,所以我无法很好地解释它,但情况似乎是“在流之外”。
浏览 0
提问于2018-11-27
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RxJava系列七
RxJava系列五
Kotlin,RxJava与RxAndroid混合开发
RxJava 2.2.0 发布,Rx 的 Java 实现
重新认识RxJava 与RxAndroid
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券