subscriber usage

gistfile1.fs

    let Run<'T when 'T: not struct and 'T:null and 'T:equality> (errorCallback, ct:CancellationToken, finished:ManualResetEvent) =
        let sub = new Subscriber<'T>()
        sub.ReceivedMessages(ct)
            |> Seq.iter (fun msg ->
                try
                    write msg
                with | ex ->
                    sub.Return msg
                    errorCallback ex)
        finished.Set() |> ignore