'Mono.and ()' не может вызываться с предоставленными параметрами

Я пытаюсь запустить образец проекта, расположенный здесь . Однако я вижу

Error:(38, 22) Kotlin: None of the following functions can be called with the arguments supplied: public final fun and(p0: ((Subscriber<in Any!>!) -> Unit)!): Mono<Void!>! defined in reactor.core.publisher.Mono public final fun and(p0: Publisher<*>!): Mono<Void!>! defined in reactor.core.publisher.Mono

в классе buildResponse функции buildResponse :

 internal class ApiHandler(val geoLocationService: GeoLocationService, val sunriseSunsetService: SunriseSunsetService, val errorHandler: ErrorHandler) { private companion object { const val ADDRESS = "address" } internal fun getLocation(request: ServerRequest) = request.pathVariable(ADDRESS).toMono() .transform(this::buildResponse) .transform(this::serverResponse) .onErrorResume(errorHandler::throwableError)!! internal fun postLocation(request: ServerRequest) = request.extract<LocationRequest>() .map(LocationRequest::address) .transform(this::buildResponse) .transform(this::serverResponse) .onErrorResume(errorHandler::throwableError)!! internal fun buildResponse(address: Mono<String>) = address.transform(geoLocationService::fromAddress) .and(this::sunriseSunset, ::LocationResponse) internal fun sunriseSunset(geographicCoordinates: GeographicCoordinates) = geographicCoordinates.toMono().transform(sunriseSunsetService::fromGeographicCoordinates) internal fun serverResponse(locationResponseMono: Mono<LocationResponse>): Mono<ServerResponse> = locationResponseMono.flatMap { ok() withBody it } } 

Я предполагаю, что API Spring изменился с момента написания этого кода, но я не могу понять, что изменить .and(...) на.

Я думаю, что это связано с изменением API API Reactor Core в 3.1.0.

Mono.and() больше не является оператором, который возвращает Tuples, но теперь он только заботится о сигналах завершения ( Mono<Void> ). Вы должны заменить этот оператор and() оператором zip или zipWith , как это предлагается в примечаниях к выпуску Reactor .

Intereting Posts
Ошибка приложения при попытке сохранить файл с помощью ObjectOutputStream Как преобразовать многие AsyncTasks в Rx Observables в Android? JsonArray в класс данных Kotlin с использованием Retrofit (ожидается BEGIN_OBJECT, но BEGIN_ARRAY) Конфигурация «compile» in устарела, но все конфигурации – это «реализация», Как создать анонимный интерфейс интерфейса? Инициализация val путем деструктуризации в Котлине Kotlin kotlinClass.class.getName () не может вернуть имя пакета, но только простое имя класса Как элегантная пара родительского и дочернего тегов в определении DSL в Kotlin Каков правильный синтаксис для переопределения функции члена интерфейса с помощью модификатора видимости? Смутно о переменной RxJava Assignment Получить ссылку на класс из функции верхнего уровня в kotlin Spring Data JPA Как использовать ноль Kotlin вместо необязательного Завершить деятельность андроида от другого с помощью Kotlin Соответствие нестандартных типов в ElementUnion Анимация (прокрутка) одна ViewGroup блокирует несвязанные виды из анимации до завершения