Exception on broadcast unregister

gistfile1.txt

Flowable
        .create<Boolean>({ emitter ->
            val broadcastReceiver = object : BroadcastReceiver() {
                override fun onReceive(context: Context?, intent: Intent?) {
                    try {
                        throw RuntimeException("Test exception")
                    } catch(e: Throwable) {
                        emitter.tryOnError(e)
                    }
                }
            }
            try {
                application.registerReceiver(broadcastReceiver, IntentFilter(LocationManager.PROVIDERS_CHANGED_ACTION))

                emitter.setCancellable {
                    throw RuntimeException("unregisterReceiver exception")
                    application.unregisterReceiver(broadcastReceiver)
                }
            } catch (e: Throwable) {
                emitter.tryOnError(e)
            }
        }, BackpressureStrategy.MISSING)
        .onErrorReturn { false }