mirror of
https://github.com/tachiyomiorg/tachiyomi.git
synced 2024-11-09 19:25:10 +01:00
more lint cleanup??
lint kept unintenting it each build so not using block comments on it
This commit is contained in:
parent
4805e54b63
commit
9036fa8ca9
@ -41,11 +41,9 @@ private suspend fun <T> Observable<T>.awaitOne(): T = suspendCancellableCoroutin
|
|||||||
}
|
}
|
||||||
|
|
||||||
override fun onError(e: Throwable) {
|
override fun onError(e: Throwable) {
|
||||||
/*
|
// Rx1 observable throws NoSuchElementException if cancellation happened before
|
||||||
* Rx1 observable throws NoSuchElementException if cancellation happened before
|
// element emission. To mitigate this we try to atomically resume continuation with exception:
|
||||||
* element emission. To mitigate this we try to atomically resume continuation with exception:
|
// if resume failed, then we know that continuation successfully cancelled itself
|
||||||
* if resume failed, then we know that continuation successfully cancelled itself
|
|
||||||
*/
|
|
||||||
val token = cont.tryResumeWithException(e)
|
val token = cont.tryResumeWithException(e)
|
||||||
if (token != null) {
|
if (token != null) {
|
||||||
cont.completeResume(token)
|
cont.completeResume(token)
|
||||||
|
Loading…
Reference in New Issue
Block a user