diff --git a/app/src/main/java/eu/kanade/tachiyomi/util/system/RxCoroutineBridge.kt b/app/src/main/java/eu/kanade/tachiyomi/util/system/RxCoroutineBridge.kt index 069906809a..d67c87b278 100644 --- a/app/src/main/java/eu/kanade/tachiyomi/util/system/RxCoroutineBridge.kt +++ b/app/src/main/java/eu/kanade/tachiyomi/util/system/RxCoroutineBridge.kt @@ -41,11 +41,9 @@ private suspend fun Observable.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 - */ + // 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 val token = cont.tryResumeWithException(e) if (token != null) { cont.completeResume(token)