CancellingAnAgent.fs

let createAgent() =
    let tokenSource = new System.Threading.CancellationTokenSource()
    Agent.Start((fun inbox -> async {
        printfn "spun up a new agent..."
        while true do
            let! data = inbox.Receive()
            let! result = // Do some async work here...
            match result with
            // Everything done, we can cancel
            | AllDone -> printfn "completed!"
                         tokenSource.Cancel()

            // More to do here, wait a bit and then try again
            | MoreToDo -> printfn "retrying in a bit..."
                          do! Async.Sleep 2500
                          inbox.Post data }), tokenSource.Token)