kotlin - 如果其中一个为空，则发布者串联

Question

我正在尝试连接两个发布者，但我知道this可以为空，我也希望结果为空。

fun Flux<String>.prefixWith(rhs: Mono<String>) = rhs
    .flux()
    .concatWith(this)

这只是按预期返回 rhs。如果 Flux为空，如何返回空的 this？

Answer 1

您可以使用hasElements()的Flux方法(doc)来检查助焊剂是否包含元素，然后使用flatMapMany，如果存在元素则返回串联，如果不存在元素则返回空助焊剂本身。

fun Flux<String>.prefixWith(rhs: Mono<String>) = this.hasElements().flatMapMany<String> {
    if (it) {
        rhs.concatWith(this) //when the flux has elements
    } else {
        this //this would be empty flux
    }
}