support stream2 in node 0.10.x

Change-Id: Ie47efba45258ce211d3d7ccff774e34d5436b351
NetEase · Apr 1, 2013 · fbdbb94 · fbdbb94
1 parent 1459522
commit fbdbb94
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/lib/connectors/hybrid/wsprocessor.js b/lib/connectors/hybrid/wsprocessor.js
@@ -32,7 +32,13 @@ Processor.prototype.add = function(socket, data) {
     return;
   }
   this.httpServer.emit('connection', socket);
-  socket.emit('data', data);
+  if(typeof socket.ondata === 'function') {
+    // compatible with stream2
+    socket.ondata(data, 0, data.length);
+  } else {
+    // compatible with old stream
+    socket.emit('data', data);
+  }
 };
 
 Processor.prototype.close = function() {