node_modules/htmlparser2/test/02-stream.js

var helper = require("./test-helper.js"),
	Stream = require("..").WritableStream,
	fs = require("fs"),
	path = require("path");

helper.mochaTest("Stream", __dirname, function(test, cb){
	var filePath = path.join(__dirname, "Documents", test.file);
	fs.createReadStream(filePath).pipe(
		new Stream(
			helper.getEventCollector(function(err, events){
				cb(err, events);

				var handler = helper.getEventCollector(cb),
				    stream = new Stream(handler, test.options);

				fs.readFile(filePath, function(err, data){
					if(err) throw err;
					else stream.end(data);
				});
			}
		), test.options)
	).on("error", cb);
});