A very simple example on how to use CrowdProcess in Node.js: https://github.com/CrowdProcess/node-crowdprocess

simple-crowdprocess-example.js

var credentials = require('./credentials.json');
var CrowdProcess = require('crowdprocess')(credentials);

function Run (d) {
  return d*2;
}

var data = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];

CrowdProcess(data, Run, function (results) {
  console.log('results:', results);
});

streams-example.js

var credentials = require('./credentials.json');
var CrowdProcess = require('crowdprocess')(credentials);
var Readable = require('stream').Readable;
var Writable = require('stream').Writable;

// the program
function Run(d) {
  return d;
}

// input stream for the program
var data = new Readable({objectMode: true});
var n = 110;
data._read = function _read () {
  if (--n)
    data.push(n);
  else
    data.push(null);
};

// results stream
var results = new Writable({objectMode: true});
results.write = function write (chunk, encoding, cb) {
  console.log('got result:', chunk);
  if (cb)
    cb();
  return true;
};


// awesome oneliner
data.pipe(CrowdProcess(Run)).pipe(results);