reactive/kotlinx-coroutines-rx2/src/RxScheduler.kt [116:130]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        handle?.dispose()
    }
    val decoratedBlock = RxJavaPlugins.onSchedule(block)
    suspend fun task() {
        if (disposable.isDisposed) return
        try {
            runInterruptible {
                decoratedBlock.run()
            }
        } catch (e: Throwable) {
            handleUndeliverableException(e, ctx)
        }
    }

    val toSchedule = adaptForScheduling(::task)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



reactive/kotlinx-coroutines-rx3/src/RxScheduler.kt [116:130]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        handle?.dispose()
    }
    val decoratedBlock = RxJavaPlugins.onSchedule(block)
    suspend fun task() {
        if (disposable.isDisposed) return
        try {
            runInterruptible {
                decoratedBlock.run()
            }
        } catch (e: Throwable) {
            handleUndeliverableException(e, ctx)
        }
    }

    val toSchedule = adaptForScheduling(::task)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -