An opinionated asynchronous stream-processing framework - View it on GitHub