Minor cleanup

(cherry picked from commit ef49fc91d8)
This commit is contained in:
arkon
2021-04-06 23:21:21 -04:00
committed by Jobobby04
parent eb88c9c94b
commit 1ba07466ef
5 changed files with 7 additions and 7 deletions
@@ -41,7 +41,7 @@ private suspend fun <T> Observable<T>.awaitOne(): T = suspendCancellableCoroutin
}
override fun onError(e: Throwable) {
/*
/*
* Rx1 observable throws NoSuchElementException if cancellation happened before
* element emission. To mitigate this we try to atomically resume continuation with exception:
* if resume failed, then we know that continuation successfully cancelled itself