// Repalce all occurrences of 'foo' in 'data.txt' with 'bar',
// and output to stdout
 
var fs = require('fs');
var replace = require('stream-replace');
 
fs.createReadStream('data.txt')
  .pipe(replace(/foo/g, 'bar'))
  .pipe(process.stdout);

// Create a server listening on port 3000 that
// proxies www.example.com, and replaces
// 'example' with 'zombocom', and 'domain' with 'web page'
 
var replace = require('stream-replace');
var http = require('http');
 
http.createServer(function handler(req, res) {
  http.request('http://www.example.com/', function onResponse(response) {
    response
      .pipe(replace(/example/ig, 'zombocom'))
      .pipe(replace(/domain/ig,  'web page'))
      .pipe(res);
  }).end();
}).listen(3000);