cwharris

var n = Math.floor(Math.random() * 4);
var result = n === 1 ? "one"
           : n === 2 ? "two"
           : n === 3 ? "three"
           : "missing-no";

cwharris

class Program
    {
        static void Main(string[] args)
        {
            Func<int, int, int> add = (a, b) => a + b;

            var obs1 = Observable.Empty<int>().Scan(add);
            var obs2 = Observable.Empty<int>().Scan(0, add);

            var obs3 = Observable.Range(1, 3).Scan(add);

cwharris

var Rx = require('rx'),
    Rx = require('./rx.helpers')
    ;

var FlowLogic = (function () {

  Rx.Internals.inherits(FlowLogic, Rx.Observable);

  // pendingPours is a behavior subject. 
  // solenoid is an observer. It represents the valve allowing drink flow.

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

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

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

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