An extension function to convert an RxJava2 single to a coroutine

SingleCoroutine.kt

suspend fun <T> Single<T>.suspendSubscribe(): T {
    return suspendCancellableCoroutine { continuation ->
        val disposable = this.subscribe({ value ->
            if (continuation.isActive) {
                continuation.resume(value)
            }
        }, { throwable ->
            if (continuation.isActive) {
                continuation.resumeWithException(throwable)
            }
        })

        continuation.invokeOnCancellation {
            disposable.dispose()
        }
    }
}