Isn't this the whole reason for ConcurrentStream, its supposed to make async streaming more ergonomic and less errorprone? [1] https://github.com/yoshuawuyts/f

Isn't this the whole reason for ConcurrentStream, its supposed to make async streaming more ergonomic and less errorprone? [1] https://github.com/yoshuawuyts/futures-concurrency/releases/tag/v7.6.0 https://github.com/yoshuawuyts/futures-concurrency/releases/...