trxcllnt

made with esnextbin

trxcllnt

made with esnextbin

trxcllnt

made with esnextbin

trxcllnt

made with esnextbin

trxcllnt

made with esnextbin

trxcllnt

made with esnextbin

trxcllnt

var Rx = require('rxjs');
var shared = new Rx.Subject();
var source = Rx.Observable
	.never()
	.finally(console.log.bind(console, "unsubscribe"))
  .multicast(shared)
	.refCount();

source.subscribe(null, null, console.log.bind(console, "1. done"));

trxcllnt

var Rx = require('rxjs/Rx.KitchenSink');
var toSubscriber = require('rxjs/util/toSubscriber').toSubscriber;

Rx.Observable.prototype.subscribe = newSubscribe;

var source = Rx.Observable.create(function (subscriber) {
  subscriber.next('foo');
  subscriber.complete();
  return function() {
    console.log('source unsubscribed');

trxcllnt

var isArray = Array.isArray;
var iterateKeySet = require("falcor-path-utils").iterateKeySet;

// module.exports = getJSON;

// debugger;
var paths = [
    ['list', 'selected', 'name'],
    ['list', [0, 1, 3, 5], 'name'],
    ['list', 5, 'name'],

trxcllnt

old fromArray with immediate scheduler x 129,353 ops/sec ±1.57% (91 runs sampled)
new fromArray with immediate scheduler x 475,989 ops/sec ±1.18% (82 runs sampled)
	267.98% faster than Rx

old from (array) with immediate scheduler x 116,648 ops/sec ±2.21% (81 runs sampled)
new from (array) with immediate scheduler x 689,305 ops/sec ±4.35% (88 runs sampled)
	490.93% faster than Rx

old from (array) with immediate scheduler x 68,486 ops/sec ±1.60% (88 runs sampled)
new from (array) with immediate scheduler x 983,076 ops/sec ±3.37% (85 runs sampled)