New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
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). |
No description provided.
The text was updated successfully, but these errors were encountered: