Minor cleanup

This commit is contained in:
arkon
2021-04-06 23:21:21 -04:00
parent 6222b47a4f
commit ef49fc91d8
5 changed files with 7 additions and 7 deletions

View File

@ -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