javad
11/02/2018, 4:48 PMSingle.await()
? The official lib only supports RxJava 2 😞Jonathan
11/02/2018, 4:48 PMjavad
11/02/2018, 4:49 PMJonathan
11/02/2018, 4:51 PMsuspendCoroutine
Here's an example:
suspend fun <T> Single<T>.await(): T = supendCancellableCoroutine { cont ->
val disposable = subscribe(
{ cont.resume(it) }, // onSuccess
{ cont.resumeWithException(it) } // onError
)
cont.invokeOnCancellation {
disposable.dispose()
}
}
javad
11/02/2018, 4:51 PMJonathan
11/02/2018, 4:53 PMZach Klippenstein (he/him) [MOD]
11/02/2018, 10:07 PMgildor
11/03/2018, 2:29 PM