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);

cwharris

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

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

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

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

cwharris

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

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

cwharris

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

  		var self = this;

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

				self.subscribe(function (source) {

					var subject = null;

cwharris

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

cwharris

Rx.Observable.prototype.autoPublish = function () {
  var source = this.publish(),
      subscribers = 0,
      connection = null,
      dispose = function () {
        if (--subscribers === 0) { connection.dispose(); }
      };

  return Rx.Observable.createWithDisposable(function (o) {
    if (++subscribers === 1) { connection = source.connect(); }

cwharris

var Rx = require('rx');

var a = new Rx.Subject();
var b = new Rx.Subject();
var c = new Rx.Subject();

var resA = Rx.Observable
  .when(
    a.and(b)
    .then(function (a, b) { return a + b; })

cwharris

var model = new Rx.Subject();
var click = new Rx.Subject();

model.latestOn(click, function (model, e) { return [model, e]; })
  .subscribe(function (x) {
    console.log(x);
  });