carbaj0
fun <A> Kind<ForIO, A>.execute(error: (Error) -> Unit = {}, success: (A) -> Unit): Disposable = fix().unsafeRunAsyncCancellable { foldResult(it, error, success) }