Observable

Observable.fs

type OnNext<'a> =  'a -> unit

type Observable<'a> =
    Observable of (OnNext<'a> -> unit) with

    static member Single (value: 'a) =
        let subscribe (onNext: OnNext<'a>) =
            onNext value
        Observable subscribe

    member this.Subscribe (onNext: OnNext<'a>) : unit =
        match this with Observable subscribe -> subscribe onNext