tristanls

(function (ctr,t) {
  
  function inc () { ctr++ }

  function display (ntps,ntpsStr,i,lps,lpsStr,ratioStr) {
    ntps= ctr*1e3/(Date.now()-t); //nextTicks per second
    ntpsStr= ", nextTicksPerSecond: "+ ntps.toFixed(1);
  
    ctr= 0;
    i= 100e6;

tristanls

var startLoop;
var startNextTick;

var size = 1000000; // million

var loopCount = 0;
var noop = 0;
var loopTest = function () {
  loopCount++;
  if ( loopCount < ( size - 1 ) )

tristanls

var startFast;
var startSlow;

var size = 1000000; // million

var loopCount = 0;
var loopTest = function () {
  loopCount++;
  if ( loopCount == ( size - 1 ) )
    console.log( 'loop result: ' + ( new Date() - startFast ) + 'ms' );

tristanls

var startFast;
var startSlow;

var size = 1000000; // million

var fast = function () {
  for ( var i = 0; i < size; i++ ) {
    ( function () {
      var j = i;
      return function () {

tristanls

{
  "message": "hello there",
  "status": "200 OK"
}

tristanls

1. General Background and Overview

• Probabilistic Data Structures for Web Analytics and Data Mining : A great overview of the space of probabilistic data structures and how they are used in approximation algorithm implementation.
• Models and Issues in Data Stream Systems
• Philippe Flajolet’s contribution to streaming algorithms : A presentation by Jérémie Lumbroso that visits some of the hostorical perspectives and how it all began with Flajolet
• Approximate Frequency Counts over Data Streams by Gurmeet Singh Manku & Rajeev Motwani : One of the early papers on the subject.
• [Methods for Finding Frequent Items in Data Streams](http://citeseerx.ist.psu.edu/viewdoc/download?doi=10.1.1.187.9800&rep

tristanls

dostuffEmitter.on('task1', function (callback) {
  dostuffEmitter.emit('task3', x, callback);
});

dostuffEmitter.on('task2', function (x, callback) {
  dostuffEmitter.emit('finish', y, callback);
});

dostuffEmitter.on('task3', function (y, callback) {
  dostuffEmitter.emit('task2', z, callback);

tristanls

dostuffEmitter.on('task2', function (x, callback) {
  if (error) {
    dostuffEmitter.emit('error', error);
    return;
  }
  dostuffEmitter.emit('telemetry', someMetricHere);
  dostuffEmitter.emit('task3', y, callback);
});

tristanls

var dostuffEmitter = new EventEmitter();

dostuffEmitter.on('task1', function (callback) {
  if (error) {
    dostuffEmitter.emit('error', error);
    return;
  }
  dostuffEmitter.emit('task2', x, callback);
});

tristanls

var dostuffEmitter = new EventEmitter();

dostuffEmitter.on('task1', function (callback) {
  dostuffEmitter.emit('task2', x, callback);
});

dostuffEmitter.on('task2', function (x, callback) {
  dostuffEmitter.emit('task3', y, callback);
});