Tadas Giniotis
12/16/2018, 8:31 PMprivate fun <F, A, B> runInAsyncContext(
f: () -> A,
onError: (Throwable) -> B,
onSuccess: (A) -> B, AC: Async<F>
): Kind<F, B> {
return AC.async { proc ->
async(CommonPool) {
val result = Try { f() }.fold(onError, onSuccess)
proc(result.right())
}
}
}
to
private fun <F, A, B> runInAsyncContext(
f: () -> A,
onError: (Throwable) -> B,
onSuccess: (A) -> B, AC: Async<F>
): Kind<F, B> {
return AC.async { proc ->
kotlinx.coroutines.experimental.async(CommonPool) {
val result = Try { f() }.fold(onError, onSuccess)
proc(result.right())
}
}
}
and it started working again.
Even though it is outdated, it seems like a good starting point to get some ideas across