implement transform stream to support both multiple messages per packet and message re-assembling from several packets