Read, write, transform data streams - View it on GitHub