It’d be nice to have an async iterator version of Generators.input. Same also with Generators.queue and Generators.observe?