kirillrakhman
12/20/2016, 10:01 AMfun <V> Observable<V>.subscribeWithContinuation(x: Continuation<V>) = subscribe(x::resume, x::resumeWithException)!!
suspend fun <V> Observable<V>.awaitFirst() : V = suspendCoroutine {
first().subscribeWithContinuation(it)
}