looping indexer

gistfile1.fs

    let Run<'T when 'T: not struct and 'T:null and 'T:equality> (errorCallback, ct:CancellationToken, finished:ManualResetEvent) = 
        let p = QueueProvider<'T>.Create()
        try 
            while not (ct.IsCancellationRequested) do
                match p.Dequeue() with
                    | null -> Thread.Sleep 1000
                    | _ as obj ->
                        try
                            write obj
                        with | ex -> 
                            p.Enqueue obj 
                            raise ex 
        with | ex -> 
            errorCallback ex
        finished.Set () |> ignore