othiym23

var cls = require('continuation-local-storage')
  , concat = require('concat-stream')
  , http = require('http')

var foo = cls.createNamespace('foo')

foo.run(function () {
  http.createServer(function(req, res) {
    req.pipe(concat(done))

othiym23

function task1(){
  // some logic
}

function task2(){
 task1();
 // other logic
}

gulp.task('task1', task1);

othiym23

The script populates a few keys in redis (assuming it is running), and once that is complete, calls a series of tests trying to get them.

Each test stores a key in cls, and compares the key it is given when calling the get function with the one in CLS, before and after invoking GET on the redis client, failing if they are not the same.

Ther are two versions of the get function

• Straight up callback
• Promise based with Q

Regardless of whether hiredis is present in the project, am getting errors as follows.

othiym23

HTTP: outgoing message end.
sending 104857600
HTTP: AGENT incoming response!
HTTP: AGENT isHeadResponse false
200
{"date":"Fri, 04 Oct 2013 01:12:40 GMT","connection":"keep-alive","transfer-encoding":"chunked"}
chunk received: 65527 (total 65527)
chunk received: 65536 (total 131063)
chunk received: 65536 (total 196599)
chunk received: 65536 (total 262135)

othiym23

var net = require('net');
var domain = require('domain');

var expected = 0, caught = 0;
process.on('exit', function () {
  assert(expected === caught);
  console.log('ok expected', expected, 'caught', caught);
});

var d = domain.create();

othiym23

var domain = require('domain');

var key = process.addAsyncListener(domain.____xXx__secret___asyncListener);

var d = domain.create();
d.on('error', ...);
d.run(function () {
  var server = net.createServer(...);
});

othiym23

var Router = require('./router');
var ns = require('./namespace-module');

var router = new Router();


router.initialize();
var NUM_TESTS = 10;

var spawnAsync = function (i) {

othiym23

var slice = [].slice;

function exportscope() {
    var args = slice.call(arguments);
    for (var i = 0; i < args.length; i++) this.exports[args[i]] = eval(args[i]);
}

var a = 1, b = 2, c = 3;

// super-ugly

othiym23

 'use strict';

(function () {
  var myfile;

  function readFileCallback(err, val) {
    if (err) throw err;
    
    myfile=val;

othiym23

MultiInstaller.prototype.forEach = function (visitor, callback) {
  var qVisitor = Q.nfbind(visitor, null)
    , qInstall = Q.nfbind(install)
    ;

  var target = this.target;
  var prefix = this.prefix;

  function process(versions, index, result) {
    if (!versions[index]) return result;