Конвертировать RxJava Single в Mono - PullRequest
0 голосов
/ 11 декабря 2018

Я новичок в RxJava и Spring webflux.Есть ли способ конвертировать RxJava Single в Mono?

Я хочу вернуть 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 возвращает текучий

1 Ответ

0 голосов
/ 11 декабря 2018

Вы можете использовать reactor.adapter.rxjava.RxJava2Adapter.singleToMono(io.reactivex.Single<T> source), который возвращает Mono<T>.

Источник: RxJava2Adapter

...