<RxJava2 Flowable onErrorReturn not called> Say I ...

# stackoverflow

[user]

RxJava2 Flowable onErrorReturn not called
Say I need to wrap BroadcastReceiver with Flowable:

Flowable
.create({ emitter ->
val broadcastReceiver = object : BroadcastReceiver() {
override fun onReceive(context: Context?, intent: Intent?) {
throw RuntimeException("Test exception")
}
}
application.registerReceiver(broadcastReceiver,...