Through stream that parses each write as a JSON message. - View it on GitHub