Splits a Node stream of protocol buffer messages - View it on GitHub