PaulMougel

process.on('message', function(m) {
  console.log('Just received a message from parent: ' + JSON.stringify(m));
  if (m.exit === "true") process.exit();
});

PaulMougel

// node: v0.10.21
// request: 2.27.0
var request = require('request');
var fs = require('fs');

var r = request.post("http://server.com:3000/");
// See http://nodejs.org/api/stream.html#stream_new_stream_readable_options
// for more information about the highWaterMark
// Basically, this will make the stream emit smaller chunks of data (ie. more precise upload state)
var upload = fs.createReadStream('f.jpg', { highWaterMark: 500 });

PaulMougel

var stream = require('stream');
var JSONStream = require('JSONStream');

var inputStream = new stream.PassThrough();
var jsonStream = JSONStream.parse('*');
var finalStream = new stream.Writable({ objectMode: true });
finalStream._write = function (doc, encoding, done) {
  console.log(doc);
  done();
};

PaulMougel

var stream = require('readable-stream');
var mmm = require('mmmagic');
var mimeChecker = new stream.Transform();
mimeChecker.data = [];
mimeChecker.mimeFound = false;
mimeChecker._transform = function (chunk, encoding, done) {
  var self = this;

  if (self.mimeFound) {
    self.push(chunk);