``` fun <A> (suspend () ->A).toObservable...

# arrow

[pakoito]

fun <A> (suspend () ->A).toObservable(): Observable<A> = Observable.create { emitter ->
  this.startCoroutine(Continuation(EmptyCoroutineContext) { result ->
    result.fold({ a -> emitter.onNext(a); emitter.onComplete() }, emitter::onError)
  })
}