Erlang Ring Problem in F# + Rx

Ring-Rx.fsx

#r @"System.Reactive.dll"

open System
open System.Reactive.Subjects
open System.Reactive.Linq

let run n m =
    let now = DateTime.Now

    let nodes = List.init n (fun _ -> new Subject<_>())
    nodes.[nodes.Length - 1]
        .Finally(fun () -> printfn "Completed in %f" (DateTime.Now - now).TotalSeconds)
        .Start() |> ignore
    Seq.iter2 (fun l r -> (l :> IObservable<_>).Subscribe(r) |> ignore) nodes nodes.Tail

    Seq.init m id |> Seq.iter nodes.Head.OnNext
    nodes.Head.OnCompleted();;

run 100 100000