代码之家 › 专栏 › 技术社区 › Piotr Aleksander Chmielowski

当平面图中的一个完成时,使原始的可观测的完成

rx-java2 kotlin

Piotr Aleksander Chmielowski · 技术社区 · 6 年前

我有一个 Observable 我正在申请 flatMap 操作员。能把这个做成原版吗 可观察的 第二个完成时完成?

这是密码。

Observable.never<Int>()
        .startWith(0)
        .doOnComplete { println("Completed") } // Not called.
        .flatMap { Observable.fromArray(1, 2, 3, 4, 5) /* Completes after 5 */ }
        .subscribe(::println)

输出是:

我正在尝试实现以下输出:

1
2
3
4
5
Completed

1 回复 | 直到 6 年前

Tuby 6 年前

materialize flatMap onComplete onNext

    Observable.<Integer>never()
            .startWith(0)
            .flatMap(integer -> Observable.range(1, 5)
                    .materialize())
            .takeWhile(notification -> notification.isOnNext())
            .map(notification -> notification.getValue())
            .doOnComplete(() -> System.out.println("Completed"))
            .subscribe(integer -> System.out.println(integer));

1
2
3
4
5
Completed

推荐文章

danny · 如何在kotlin中使用图形2d与paint()

1 年前

manabreak · 如何在Jetpack Compose中通过叠加可组合的拖拽交互,但捕捉点击交互?

2 年前

danilo · Android在谷歌sigin中使用Firebase Auth时没有sigin

2 年前

Murad Axundov · 我的功能只有一小部分有效。怎样(科特林)

2 年前

Vetalll · Java、JDBC在重复密钥更新通配符上的插入

2 年前

jvargas · 如何获取上个月的第一天和最后一天以及一年的第一天

2 年前

Michel · 在Android上后台播放音频超过一分钟

2 年前

mepi0011 · Android Studio中的Kotlin持续时间问题

2 年前

Ashish Joshi · 未使用导航图弹出片段

2 年前

Tommy - · 为什么回收器视图在片段中有NullPointerException?

2 年前