This repository has been archived by the owner on Jun 1, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 25
Add uncancelable
for IO
#138
Comments
👍 |
@alexandru So the actions would be: Create a Implement static uncancellable<A>(io: IO<A>) {
return IO.asyncUnsafe<A>((ctx, cb) => {
const ec = ctx.scheduler;
ec.trampoline(() => {
const conn = stackedUncancelableRef; // stackedUncancelableRef being a singleton instance of StackedUncancelable defined in funfix-effect
IO.unsafeStart(io, ctx, ioSafeCallback(ec, conn, cb));
});
});
return io;
} Add the flow definitions (not versed into it, but looks definitely possible) Everything with tests and frenchy english comments! |
@alexandru sorry to bug you, but can you confirm / infirm on the approach? |
@alexandru pinging again as I need safe cancellation to hit prod quite soon (not joking). |
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
No description provided.
The text was updated successfully, but these errors were encountered: