それぞれについて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）！）：Completable！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ですか？
私は答えを見つけました：
fun process(): Completable =
eventsDao.findAll()
.flatMapCompletable(this::processEvent)
fun processEvent(event: Event) =
send(event).concatWith(validate(event))
私はそれを行うためのアドバイスやより良い方法を本当に感謝します
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加