Posted at

RxJava を Kotlin で利用する時に andThen や concatWith でラムダ式を使ってはいけない

More than 1 year has passed since last update.

完全にハマりました。

RxJava (RxKotlin 含む) を Kotlin で利用している場合に、 Completable の andThenconcatWith でラムダ式を使用してはいけません。


ダメな例

Completable.complete()

.andThen{ Completable.complete() }
.test()
.assertComplete()

この場合、このストリームは Complete しません。

ラムダ式を使用すると内部で emitter に emit されなくなってしまうようです。1