Erlang Ring Rx new

Erlang-Rx.fs

#r @"C:\Projects\Lib\System.Reactive.Interfaces.dll"
#r @"C:\Projects\Lib\System.Reactive.Core.dll"
#r @"C:\Projects\Lib\System.Reactive.Linq.dll"

open System
open System.Linq
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)
        .RunAsync(Threading.CancellationToken.None) |> 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 10000 1000