将 RxJava Single 转换为 Mono

Question

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

我想 return 从以下函数得到一个 Mono<String>。

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

findChannels return可流动

Answer 1

您可以使用 reactor.adapter.rxjava.RxJava2Adapter.singleToMono(io.reactivex.Single<T> source) 其中 returns Mono<T>。

来源：RxJava2Adapter