cwharris

        Rx.Observable.select = function (element, source) {
            return source.select(function (value) {
                return {
                    element: element,
                    value: value
                };
            });
        };

cwharris

Rx.Observable.prototype.obsFilter = function (func) {

  		var self = this;

			return Rx.Observable.createWithDisposable(function (o) {

				self.subscribe(function (source) {

					var subject = null;

cwharris

using System;
using System.Reactive.Linq;
using System.Reactive.Subjects;

namespace ReactivePrimitives
{
    class Program
    {
        static void Main(string[] args)
        {

cwharris

function flatMap (array, func) {
    return Array.prototype.concat.apply([], array.map(func));
};

cwharris

        static void Main(string[] args)
        {
            var items = new[] { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9 }
                .Select(x =>
                {
                    Console.WriteLine(x);
                    return x;
                })
                .Select(x => Observable.Range(x, 1))
                .Concat()

cwharris

  Rx.Observable.combineTemplate = function(sources) {
    
    var keys = [];
    var values = [];

    for (var key in sources) {
      keys.push(key);
      values.push(sources[key]);
    }

cwharris

    // combineLatest(obs1, obs2, selector)
    // combineLatest([obs1, obs2], selector)
    observableProto.combineLatest = function () { 
        var args = slice.call(arguments);
        
        // (args[0] instanceof Array ? args[0] : args).unshift(this);
        if (args[0] instanceof Array) {
            args[0].unshift(this);
        } else {
            args.unshift(this);