emitter_isDisposed_RC.kt

val checkLock = Object()
val disposeLock = Object()

val completable = Completable.create { emitter ->
    synchronized(checkLock) {
        checkLock.notify()
    }
    if (!emitter.isDisposed) {
        synchronized(disposeLock) {
            try {
                disposeLock.wait()
            } catch (e: InterruptedException) {

            }
        }
        println("throw error")
        emitter.tryOnError(RuntimeException("Race-condition"))
    }
}.subscribeOn(Schedulers.io())

lateinit var disposable: Disposable
synchronized(checkLock) {
    disposable = completable.subscribe({
        //success
    }, {
        //error is handled
    })
    checkLock.wait()

}
synchronized(disposeLock) {
    println("dispose")
    disposable.dispose()
    disposeLock.notify()
}