I've built an open source streaming library for async pipelinesgithub.com/ju-bezdek1 pointju-bezdeka year ago