To process multiple events from a stream concurrently, we should consider to use for_each_concurrent and try_for_each_concurrent were it´s desired. For example, this could be used in conns::listen() for writing concurrently data to the streams/peers.
To process multiple events from a stream concurrently, we should consider to use
for_each_concurrent
andtry_for_each_concurrent
were it´s desired. For example, this could be used inconns::listen()
for writing concurrently data to the streams/peers.https://rust-lang.github.io/async-book/05_streams/02_iteration_and_concurrency.html