THIS LIBRARY IS DEPRECATED: Please use streaming-commons instead - View it on GitHub