A Swiss army knife for async iterables. Designed to replace your streams. - View it on GitHub