pause and resume on an http stream

http-stream-test.js

var http = require('http');
var server = http.createServer(function (req, res) {

		var nb_chunk = 0;
		res.write('Shifting ...');
		req.pause();
		req.setEncoding('utf-8');
		req.on('data', function(chunk) {
				nb_chunk++;
				res.write('Request Chunked #'+nb_chunk+' : '+chunk[0]+chunk[1]+chunk[2]+'\n');

				if (nb_chunk < 5) {
					// 1 chunk per second
					res.write('Waiting...');
					req.pause();

					setTimeout(function(){
							res.write('... Resume !'+'\n');
							req.resume();
						}, 1000);
				} else {

					res.write('Request Stoped'+'\n');
					res.end(); // on stoppe le streaming au bout de 5 chunk
				}
		});
		req.on('end', function() {
				res.write('Request Completed'+'\n');
				res.end();
		});

		setTimeout(function(){
				console.log('... Start-up !');
				req.resume();
			}, 1000);
});
server.listen(1337, '127.0.0.1');
console.log('Server running at http://127.0.0.1:1337/');

var options = {
	host: '127.0.0.1',
	port: 1337,
	path: '/',
	method: 'PUT'
};

var req = http.request(options, function(res) {
		res.setEncoding('utf8');
		res.on('data', function (chunk) {
				process.stdout.write(chunk);
		});
		res.on('end', function () {
				server.close();
				console.log('Server stopped.');
		})
});
req.on('error', function(e) {
		console.log('problem with request: ' + e.message);
});

// write data to request body
for(var i=0; i < 20000; i++) {
	req.write('0123456789\n');
}
req.end();