There shouldn’t be any need for fiber and bracket....

# arrow

[simon.vergauwen]

There shouldn’t be any need for fiber and bracket. IO can run in a cancellable way with a cancelable reference typealias Disposeable = () -> Unit. Whenever the coroutine gets cancelled you can also cancel the underlying IO using that reference.

fun <A> IOOf<A>.suspendCancellable() : Either<Throwable, A> =
 suspendCancellableCoroutine { continuation ->
    val disposable = fix().unsafeRunSyncCancellable {  continuation.resume(it) }
    continuation.invokeOnCancellation { disposable.invoke() }
  }

[than_]

thank you 🙂