Changed onData to stage incomplete messages and reassemble them properly
before emitting them each in full. Currently an exploration of the solution
rather than a complete implementation. I'd like to create a promise object on
_partialMessage with a timer to emit and flush after a timeout. Also need to
strip illustrative print statements.