diff --git a/src/client.js b/src/client.js index 24131b6..d990f01 100644 --- a/src/client.js +++ b/src/client.js @@ -108,7 +108,7 @@ Client.prototype.setSocket = function(socket) { incomingBuffer = incomingBuffer.slice(packetLengthField.size + packetLengthField.value); if (self.compressionThreshold == -2) { - process.nextTick(afterParse.bind(null, null, parsePacketData(buf, self.state, self.isServer, self.packetsToParse))); + setImmediate(afterParse, null, parsePacketData(buf, self.state, self.isServer, self.packetsToParse)); } else { parseNewStylePacket(buf, self.state, self.isServer, self.packetsToParse, afterParse); } diff --git a/src/protocol.js b/src/protocol.js index f6d3418..33c8c35 100644 --- a/src/protocol.js +++ b/src/protocol.js @@ -1626,7 +1626,7 @@ function parseNewStylePacket(buffer, state, isServer, packetsToParse, cb) { } }); } else { - process.nextTick(cb.bind(null, null, parsePacketData(buf, state, isServer, packetsToParse))); + setImmediate(cb, null, parsePacketData(buf, state, isServer, packetsToParse)); } }