通量完成时返回值？

Question

val myId : Mono<String> = fetchMyId()
myId.flatMap { id ->
     someFlux.map { .. }.doOnNext { ... }.returnOnComplete(Mono.just(id))
}

Answer 1

您可以使用then(Mono ) 运算符，因为根据文档，它的操作完全符合您的要求：

让这个流量完成，然后播放来自提供的单声道的信号。

换句话说，忽略这个流量的元素，并将其完成信号转换为提供的单声道 的发射和完成信号。错误信号在生成的单声道 中重播。

java prettyprint-override">Mono
    .just("abc")
    .flatMap(id -> Flux.range(1, 10)
        .doOnNext(nr -> logger.info("Number: {}", nr))
        .then(Mono.just(id)))
    .subscribe(id -> logger.info("ID: {}", id));