Rx pipelining with F#

rx-pipeline-example.fs

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

let seq = [1; 2; 3; 4].ToObservable()

// Add curryable versions of Rx methods
let select (selector:'TSource -> 'TResult) (source:IObservable<'TSource>) =
    Observable.Select(source, selector)

let where (predicate:'TSource -> bool) (source:IObservable<'TSource>) =
    Observable.Where(source, predicate)

let newSeq = seq |>
             where (fun num -> num % 2 = 0) |>
             select (fun num -> num + 1)

ignore(newSeq.Subscribe(fun item -> printfn "%d" item))