rx-java - RxJava2で例外をサイレントにスキップする方法は?

Question

次のようなデータフローがあります。

Observable
    .fromFuture(
        CompletableFuture.supplyAsync { // First remote call returns Future<List<Type>>
            listOf(1, 2, 3, 57005, 5)
        },
        Schedulers.computation()
    )
    .flatMap { it.toObservable() } // I turn that list into a stream of single values to process them one by one
    .map {
        CompletableFuture.supplyAsync { // This remote call may fail if it does not like the input. I want to skip that failures and continue the stream like the fail never occurred.
            if (it == 0xDEAD) {
                throw IOException("Dead value!")
            }

            it
        }
    }
    .flatMap {
        Observable.fromFuture(it) // Turn that Futures into a stream of Observables once again
    }
    .doOnNext {
        println(it) // Debug
    }
    .blockingSubscribe()

ビジネス ロジック (実際には s を返すFuture) をに置き換えましたCompletableFuture.supplyAsync。はい、これは Kotlin ですが、意図は理解できたと思います。

「デッド」値 ( 57005, 0xDEAD) をコメントすると、出力は次のようになります。

1
4
9
25

しかし、その「死んだ」値がストリームに現れると、失敗します:

1
4
9
Exception in thread "main" java.lang.RuntimeException: java.util.concurrent.ExecutionException: java.io.IOException: Dead value!
    at io.reactivex.internal.util.ExceptionHelper.wrapOrThrow(ExceptionHelper.java:45)
    at io.reactivex.internal.operators.observable.ObservableBlockingSubscribe.subscribe(ObservableBlockingSubscribe.java:86)
    at io.reactivex.Observable.blockingSubscribe(Observable.java:5035)
    at by.dev.madhead.rx.TestKt.main(test.kt:41)
Caused by: java.util.concurrent.ExecutionException: java.io.IOException: Dead value!
    at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
    at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
...

私はRXの初心者なので、すぐに解決策をグーグルで検索しました: onExceptionResumeNext: Observable.fromFuture(it)--> Observable.fromFuture(it).onExceptionResumeNext { Observable.empty<Int>() }. しかし、私のアプリケーションは永遠にハングアップします (私が期待する出力を生成した後)。ストリームは決して終わらないようです。

Observableどういうわけかそれを「シャットダウン」する必要がありますか？それとも、より一般的には、RX を使用する場合の適切なアプローチですか? 別の方法で考え直す必要がありますか？