pingable

Ping a stream once in a while. If the ping times out the stream will be destroyed.

npm install pingable

Usage

var pingable = require('pingable');

pingable(stream, {
	interval: 15000, // how often should we ping it,
	timeout: 5000    // whats the ping timeout?
}, function(cb) {
	// do the ping somehow
	stream.write('ping');

	// when the ping is completed call the cb
	stream.once('data', function() {
		cb();
	});
});

stream.on('close', function() {
	// if the ping fails stream.destroy will be called
	// which usually triggers a close
});

If you are streaming some sort of protocol thats supports a ping just do

pingable(stream, opts, function(cb) {
	stream.ping(cb);
});

License

MIT