es.through undefined file

gulpfile.js

var gulp = require('gulp');
var es = require('event-stream');

function plugalug() {
  function queue(file) {
    if (typeof file === 'undefined') {
      throw new Error('File was undefined!');
    }
  }
  function end() {
    console.log('Stream ended');
  }
  return es.through(queue, end);
}

gulp.task('test-watch', function() {
  return gulp.src('gulpfile.js')
    .pipe(plugalug());
})

gulp.task('default', function() {
  gulp.watch('gulpfile.js', function(event) {
    gulp.run('test-watch')
  });
});