Turn an event stream into an async iterable - View it on GitHub