Intereting Posts
Java не разрешает окончательные методы по умолчанию .. но делает Котлин? Как использовать простое наследование для класса данных? Тестирование AnkoComponents и насмешка AnkoContext Как обмениваться изображениями на Android с помощью Kotlin? "Coroutine local" переменные в kotlin Простой способ отображения моделей данных в модели домена Android Parcelable в Kotlin: CREATOR не найден на Parcelable class Firebase Storage OnsuceessListner в котлин не показывается Спецификация Jpa, чтобы найти подмножество значения поля Как я могу инициализировать переменную перед каждым тестом, используя kotlin-test framework Возвращать двойной индекс элемента коллекции при повторении Как преобразовать выражение назначения Java в Kotlin AndroidStudio / Kotlin – Неразрешенная ссылка: ReadWriteProperty – Kotlin версия 1.0.0-beta-1038 Могу ли я написать функцию расширения Kotlin, которая использует автоспуск Spring bean? Класс данных Котлина == Структура C #?

Цепочка ошибок Завершение после flatMapCompletable

Для каждого Event , мне нужно отправить его и проверить его. У меня есть этот код:

 fun process(): Completable = eventsDao.findAll() .flatMapCompletable(this::sendEventToServer) .andThen(this::validate) //Error here fun send(event: Event): Completable = //code fun validate(event: Event): Completable = //code 

Ошибка: (14, 18) Ни одна из следующих функций не может быть вызвана с предоставленными аргументами: @CheckReturnValue @SchedulerSupport public final fun andThen (p0: ((CompletableObserver) -> Unit)!): Завершен! определен в io.reactivex.Completable

@CheckReturnValue @SchedulerSupport public final fun andThen (p0: ((MaybeObserver) -> Unit)!): Может быть <(??? .. ???)>! определен в io.reactivex.Completable

@CheckReturnValue @SchedulerSupport public final fun andThen (p0: ((Observer) -> Unit)!): Observable <(??? .. ???)>! определен в io.reactivex.Completable

и так далее

Проблема в том, что здесь:

 .andThen(this::validate) 

У меня нет самого event . Как я могу Completable эти Completable ?

Я нашел ответ:

 fun process(): Completable = eventsDao.findAll() .flatMapCompletable(this::processEvent) fun processEvent(event: Event) = send(event).concatWith(validate(event)) 

Я буду очень признателен за любые советы или лучший способ сделать это