AwaitObservable does not call cancellation continuation if the computation is canceled before the next observation
Closed this issue · 3 comments
I posted this as a question on StackOverflow here:
http://stackoverflow.com/questions/28250201/fsharpx-async-awaitobservable-does-not-call-cancellation-continuation
It seems to me that the problem is that the definition of AwaitObservable only calls one of the continuation functions if the observable sequence has a next value (or error) before cancellation occurs. It needs to also register a callback with the cancellation token which will call the cancellation continuation and Dispose the resulting CancellationTokenRegistration on the next element in the sequence. I'm a bit out of my depth trying to implement this. Any thoughts?
I have just seen that the current version already contains this fix:
12e93c8.
I was thrown by the fact that the NuGet version doesn't have this implemented yet. Sorry about raising it.
Hello, I've got something new for you, you'll definetely love it, take a look at http://phejyfronky.realfreedomonline.com/lnvxu
Sincerely yours, blynch23@ntlworld.com
Yo!
I just wanted tosay Hi and also show you something really cool, just take a look http://slewyrovi.transmediastorytelling.tv/lnzzkc
Very truly yours, blynch23