commit 8d8a8fb1b1267576a1bfc21e9240b0ea52106f90
author Vsevolod Tolstopyatov <qwwdfsad@gmail.com> Wed Mar 04 23:33:18 2020 +0300
committer GitHub <noreply@github.com> Wed Mar 04 23:33:18 2020 +0300
tree 17c326ec66ce97344a8993ed5a3a06c74671279c
parent d831a862cb688536d564efb1e98af8e3272c31ba

Reuse RxJava built-in disposed Disposable (#1841)

reactive/kotlinx-coroutines-rx2/src/RxConvert.kt

diff --git a/reactive/kotlinx-coroutines-rx2/src/RxConvert.kt b/reactive/kotlinx-coroutines-rx2/src/RxConvert.kt
index 36e8dd9..0be606f 100644
--- a/reactive/kotlinx-coroutines-rx2/src/RxConvert.kt
+++ b/reactive/kotlinx-coroutines-rx2/src/RxConvert.kt
@@ -100,12 +100,7 @@
     }
 
     subscribe(observer)
-    awaitClose { disposableRef.getAndSet(Disposed)?.dispose() }
-}
-
-private object Disposed : Disposable {
-    override fun isDisposed() = true
-    override fun dispose() = Unit
+    awaitClose { disposableRef.getAndSet(Disposables.disposed())?.dispose() }
 }
 
 /**