Simple multiple consumer model using structured concurrency?

Thanks. In the end, the fact that AsyncStream evolved to allow multiple readers gave me exactly what I wanted: one entity pushing data, multiple entities "popping" (aka reading) the data and doing whatever they like with it.

1 Like