Implemented heartbeats

xantus · Jun 26, 2010 · 57c8d37 · 57c8d37
1 parent 5e32922
commit 57c8d37
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/socket.io/transports/websocket.js b/lib/socket.io/transports/websocket.js
@@ -37,9 +37,14 @@ exports.websocket = Client.extend({
 		this.connection.write(headers.concat('', '').join('\r\n'));
 		this.connection.addListener('end', function(){ self._onClose(); });
 		this.connection.addListener('data', function(data){ self._handle(data); });
-		if (this._proveReception()) {
+
+		if (this._proveReception()){
 			this._payload();
 		}
+
+		setInterval(function(){
+			self._write(JSON.stringify({heartbeat: '1'}));
+		}, 10000);
 	},
 
 	_handle: function(data){