If you have 1 million items, we will get 8 of those items and start processing them. We won’t touch the remaining 999992 items until there is a space. This is so Task.async_stream can also consume streams without loading them all upfront, it will only get what is needed.
Exactly the clarification I was looking for! Awesome.
Thanks so much for the work and taking time to clear it up. Huge help.