将 RxJava Single 转换为 Mono

Question

我是 RxJava 和 Spring webflux 的新手。有没有办法将 RxJava Single 转换为 Mono？

我想Mono<String>从以下函数返回 a 。

private Single<String> toNotification(PU update, Tx<PP> tx) {
    return findChannels(update.partyId(), update.notificationId(), tx)
        .toList()
        .flatMap(f -> Single.just("test"));
}

findChannels 回报可流动

Answer 1

您可以使用reactor.adapter.rxjava.RxJava2Adapter.singleToMono(io.reactivex.Single<T> source)which 返回Mono<T>。

来源：RxJava2Adapter