diff --git a/lib/msgpack.js b/lib/msgpack.js index 67c8d9e..f3d0271 100644 --- a/lib/msgpack.js +++ b/lib/msgpack.js @@ -74,7 +74,6 @@ var Stream = function(s) { break; } - self.emit('msg', msg); if (unpack.bytes_remaining > 0) { self.buf = self.buf.slice( self.buf.length - unpack.bytes_remaining, @@ -83,6 +82,7 @@ var Stream = function(s) { } else { self.buf = null; } + self.emit('msg', msg); } }); };