var stream = require('connect-stream'); // function
app.use(stream(path.resolve('public')));

app.get(function (req, res) {
  return res.stream('movie.mp4');
});

stream = require('connect-stream');
 
app.use(stream(path.resolve('public'), { // root path for static files. defaults to `process.cwd()`
  trim: false, // do not trim query strings
  trim: true, // trim all query strings using url.parse
 
  concatenate: 'resolve', // use path.resolve on concatenate root and src path
  concatenate: 'join', // use path.join on concatenate root and src path
 
  passthrough: true, // calls next() instead of returning a 404 error
  passthrough: false, // returns 404 when a file is not found
 
  cache: { // specify cache:false to turn off caching entirely
    fd: {
      max: 1000, // number of fd's to hang on to
      maxAge: 1000 * 60 * 60, // amount of ms before fd's expire
    },
 
    stat: {
      max: 5000, // number of stat objects to hang on to
      maxAge: 1000 * 60, // number of ms that stats are good for
    },
 
    content: {
      max: 1024 * 1024 * 64, // how much memory to use on caching contents
      maxAge: 1000 * 60 * 10, // how long to cache contents for
    }
  }
}));
 
var callback = function (err, range, isFirstStream) {
  console.error(err); // instanceof Error or null
  console.log(range);
  // isArray ([ini, end])         : on range request
  // isArray ([0, stat.size - 1]) : on normal request
  // Null                         : on error
  console.log(isFirstStream);
  // bool, request is first range request or not
};
 
app.get(/^\/(.*)\.mp4$/, function (req, res) {
  res.stream(req.params[0] + '.mp4', callback);
});
 
var options = {
  headers: {
    'content-type': 'application/octet-stream',
    'cache-control': 'public'
  }
};
 
app.get(/^\/download\/(.*)\.mp4$/, function (req, res) {
  res.stream(req.params[0] + '.mp4', options, callback);
});

app.use(require('connect-stream'));    // old
app.use(require('connect-stream')());  // new

var stream = require('connect-stream');
app.use(stream(path.resolve('public')));
 
app.get(function (req, res) {
  res.stream('/tmp/a.mp4');
  // old, always stream "/tmp/a.mp4"
  // new, stream from "public/tmp/a.mp4"
});

var stream = require('connect-stream');
app.use(stream(path.resolve('public'), {
  concatenate: 'resolve'
});
 
app.get(function (req, res) {
  res.stream('/tmp/a.mp4');
  // old, always stream "/tmp/a.mp4"
  // new, stream from "/tmp/a.mp4"
});

app.get('/movie.mp4', function (req, res) {
  res.stream('movie.mp4', function (err, range, isFirstStream) {
    if (isFirstStream) {
      countUpYourDatabaseHere();
    }
  });
});