You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
37 lines
963 B
JavaScript
37 lines
963 B
JavaScript
var net = require('net');
|
|
var stream = require("stream");
|
|
var util = require('util');
|
|
|
|
function MyTransformStream(options) {
|
|
stream.Transform.call(this, options);
|
|
}
|
|
util.inherits(MyTransformStream, stream.Transform);
|
|
|
|
MyTransformStream.prototype._transform = function _transform(chunk, encoding, callback) {
|
|
console.log("Got chunk, length", chunk.length);
|
|
this.push(chunk);
|
|
return callback();
|
|
};
|
|
|
|
var transformStream = new MyTransformStream({
|
|
highWaterMark: 200 * 102
|
|
});
|
|
|
|
transformStream.on('end', function onEnd() {
|
|
console.log('Got end on transform stream!');
|
|
});
|
|
|
|
// Start reading on the transform stream so that
|
|
// the pipeline is kept flowing
|
|
//transformStream.on('data', function() {});
|
|
|
|
var server = net.createServer(function onConnection(socket) {
|
|
// Make sure that libuv's loop is not kept alive by the server's handle
|
|
server.unref();
|
|
socket.pipe(transformStream);
|
|
});
|
|
|
|
server.listen(4242, function() {
|
|
console.log('server listening...');
|
|
});
|