socket: use stream2 Readable interface

lib/transport.socket.js

@@ -176,7 +176,7 @@ function SocketTransport(socket) {
   this.remoteAddress = socket.remoteAddress;
 
   this.socket.setEncoding('utf8');
-  this.socket.on('data', this._onSocketData.bind(this));
+  this.socket.on('readable', this._onSocketReadable.bind(this));
 
   common.forwardMultipleEvents(this.socket, this, [
     'error',
@@ -212,12 +212,18 @@ SocketTransport.prototype.end = function(data) {
   this.socket.destroy();
 };
 
+SocketTransport.prototype._onSocketReadable = function() {
+  let chunk = null;
+  while ((chunk = this.socket.read()) !== null)
+    this._buffer += chunk;
+  this._processData();
+};
+
 // Socket data handler
 //   data - data received
 //
-SocketTransport.prototype._onSocketData = function(chunk) {
+SocketTransport.prototype._processData = function() {
   const packets = [];
-  this._buffer += chunk;
 
   try {
     this._buffer = jsrs.parseNetworkPackets(this._buffer, packets);