Estou ficando um pouco louco aqui. Estou tentando criar umObservable<BigDecimal> função de extensão (no RxJava 2.x) para emitir a média das emissões, mas estou recebendo um erro de compilação com oSingle.zip() função. Alguém tem alguma idéia do que estou fazendo de errado? Tentei ser explícito com todos os meus tipos também e isso não funcionou ...

import io.reactivex.Observable
import io.reactivex.Single
import java.math.BigDecimal


fun Observable<BigDecimal>.sum() = reduce { total, next -> total + next }

//compile error
fun Observable<BigDecimal>.average() = publish().autoConnect(2).let {
    Single.zip(it.sum().toSingle(), it.count()) {
        sum, count -> sum / BigDecimal.valueOf(count)
    }
}