gistfile1.js

/*jshint node:true strict:true laxcomma:true es5:true*/

"use strict";

var http = require('http')
  , Stream = require('stream')
  , fs = require('fs')
  , path = require('path')
  , server
  ;

var s = new Stream()
  , bytes = 0
  ;
s.writable = true;

s.write = function (buf) {
  bytes += buf.length;
};

s.end = function (buf) {
  if (arguments.length) {
    s.write(buf);
  }

  s.writable = false;
  console.log(bytes + ' bytes written');
};

s.destroy = function() {
  s.writable = false;
};

fs.createReadStream('/etc/passwd').pipe(s, { end: false });
s.end("ii");

If i pass { end: true } as options, the output is "2190 bytes written"