AsyncResult+FromCoroutine.kt

fun <Element> AsyncResult.Companion.fromCoroutine(
    source: suspend () -> Element
): AsyncResult<Element> {
    return create { emitter ->

        val job = CoroutineScope(defaultDispatcher).launch {
            try {
                val result = source.invoke()
                emitter.onSuccess(result.makeShared())
            } catch (error: Throwable) {
                emitter.onError(error.makeShared())
            }
        }

        emitter.disposable = {
            job.cancel()
        }
    }
}