Added a data stream class to use streaming semantics when publishing data. Updated machine config to use this stream instead of an eventemitter.