Turn an asynchronous function into a through stream - View it on GitHub