jhusain

function fromEvent(dom, eventName) {
    return {
        forEach: function(observer) {
            var handler = (e) => {
                observer.onNext(e);
            };
            dom.addEventListener(eventName, handler);

            // Subscription
            return {

jhusain

// When you click the button on the right, this program
// retrieves a stock quote from a stubbed method. If the
// button is clicked while a (stubbed/fake) network request 
// is in-flight, then the fake request is cancelled and
// a new one is issued. To confirm this, press the button 
// several times and notice that only one stock quote is 
// returned.

var Task = require('task-lib');
var getQuoteButton = document.createElement('button');

jhusain

// When you click the button on the right, this program
// retrieves a stock quote from a stubbed method. If the
// button is clicked while a (stubbed/fake) network request 
// is in-flight, then the fake request is cancelled and
// a new one is issued. To confirm this, press the button 
// several times and notice that only one stock quote is 
// returned.

var Task = require('task-lib');
var getQuoteButton = document.getElementById('getQuote');

jhusain

interface Iterable {
    Generator @@iterator(Generator);
}

interface Observable {
    Generator observer(Generator);
}

Array.prototype[@@observer] = function(generator) {
    var decoratedGenerator = Object.create(generator),

jhusain

// example using the raf module from npm. try changing some values!

var Rx = require('rx');
window.Rx = Rx;
!function(e){if("object"==typeof exports)module.exports=e();else if("function"==typeof define&&define.amd)define(e);else{var f;"undefined"!=typeof window?f=window:"undefined"!=typeof global?f=global:"undefined"!=typeof self&&(f=self),(f.falkor||(f.falkor={})).PathEvaluator=e()}}(function(){var define,module,exports;return (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);throw new Error("Cannot find module '"+o+"'")}var f=n[o]={exports:{}};t[o][0].call(f.exports,function(e){var n=t[o][1][e];return s(n?n:e)},f,f.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(_dereq_,module,exports){
var Rx = _dereq_("../src/rx.ultralite");
var Observable = Rx.Observable,
    Disposable = Rx.Disposable,
    sentinelSize = 50,
    isArray = Ar

jhusain

  /*
   * Performs a exclusive map waiting for the first to finish before subscribing to another observable.
   * Observables that come in between subscriptions will be dropped on the floor.
   * @param {Function} selector Selector to invoke for every item in the current subscription.
   * @param {Any} [thisArg] An optional context to invoke with the selector parameter.
   * @returns {Observable} An exclusive observable with only the results that happen when subscribed.
   */
  observableProto.exclusiveMap = function (selector, thisArg) {
    var sources = this;
    return new AnonymousObservable(function (observer) {

jhusain

  /*
   * Performs a exclusive waiting for the first to finish before subscribing to another observable.
   * Observables that come in between subscriptions will be dropped on the floor.
   * @returns {Observable} A exclusive observable with only the results that happen when subscribed.
   */
  observableProto.exclusive = function () {
    var sources = this;
    return new AnonymousObservable(function (observer) {
      var hasCurrent = false,
        isStopped = false,

jhusain

var print = console.log.bind(console);

// partial implementation of Array.from
Array.from = function(iterable) {
    var results = [];
    for(var x of iterable) {
        results.push(x);
    }
    return results;
};