asynchronous - Fsharpx Async.AwaitObservable 不调用取消继续

Question

我正在尝试使用 Fsharpx' Async.AwaitObservable在使用 Async.StartWithContinuations 启动的异步工作流中.出于某种原因，如果用于启动此工作流的取消 token 在等待 observable 时被取消(但不是在工作流的其他部分期间)，则永远不会调用取消延续。但是，如果我把它放在 use! __ = Async.OnCancel (interruption) 中，然后中断函数确实被调用。有人可以澄清为什么会发生这种情况，最好的方法是什么，并确保始终调用其中一个延续函数？

open System
open System.Reactive.Linq
open FSharp.Control.Observable
open System.Threading

[<EntryPoint>]
let main _ =
    let cancellationCapability = new CancellationTokenSource()

    let tick = Observable.Interval(TimeSpan.FromSeconds 1.0)
    let test = async {
        let! __ = Async.AwaitObservable tick
        printfn "Got a thing." }

    Async.StartWithContinuations(test,
        (fun () -> printfn "Finished"),
        (fun exn -> printfn "Error!"),
        (fun exn -> printfn "Canceled!"),
        cancellationCapability.Token)

    Thread.Sleep 100
    printfn "Cancelling..."
    cancellationCapability.Cancel()

    Console.ReadLine() |> ignore
    0 // return an integer exit code

Answer 1

在我看来，如何实现 AwaitObservable 也是一个问题。祝你好运。

也就是说，您可以在客户端代码中使用的一种解决方法是将 AwaitObservable 包装在一个任务中:

async {
    let! ct = Async.CancellationToken
    let! __ = 
        Async.StartAsTask(Async.AwaitObservable tick, cancellationToken = ct)
        |> Async.AwaitTask
    printfn "Got a thing." 
}

不理想，但有效。