带有toList的RxJava平面图

Question

有人能解释一下如何在RxJava中通过平面图运算符传递完整信号吗？

如果flatMap操作符被注释，我可以得到从1到10的数字列表，这意味着toList将收到onComplete信号。但当我想在flatMap中进一步处理数据时，它会消耗一个完整的信号，而我无法得到任何结果。如何通过flatMap操作符传递onComplete信号？

我有以下简单的程序：

fun main(args: Array<String>) {
    notify()
            .flatMapMaybe { processData(it) }
            .toList()
            .subscribe(
                    { println("onNext: $it") },
                    { println("onError: ${it.message}") }
            )
}

fun notify(): Flowable<Int> {
    return Flowable.create({ emitter ->
        val random = Random()
        for (index in 1..10) {
            emitter.onNext(index)
            Thread.sleep((random.nextInt(500)).toLong())
        }
        emitter.onComplete()

    }, BackpressureStrategy.BUFFER)
}

fun processData(data: Int): Maybe<String> {
    return Maybe.fromCallable { data }
            .flatMap {
                if (it.mod(2) == 0) {
                    Maybe.fromCallable { it.toString() }
                } else {
                    Maybe.never()
                }
            }
}

Answer 1

而不是返回Maybe。永远不要使用也许。empty（）。根据文档，可能。empty（）应该立即发布onComplete（）。