node-streams.js

var fs = require('fs'),
  Readable = require('stream').Readable,
  http = require('http'),
  port = 4000,
  count = 0,
  server;

server = http.createServer(function(req, res) {
  var stream = new Readable;

  count++;

  stream.push('This is a stream!');
  stream.push('\n');
  stream.push('Count: ' + count);
  stream.push('\n');
  stream.push('--------------------');
  stream.push('\n');
  stream.push(null);

  stream.pipe(process.stdout);
  stream.pipe(res);
});

server.listen(port);

console.log('Listening on localhost:' + port);