A(n opinionated) boilerplate for processing stuff using streams, channels and persistent storage - View it on GitHub