You could use async_channel [1] it provides async multi-producer multi-consumer.

[1]: https://docs.rs/async-channel/latest/async_channel/