Function broadcast_concurrent

async fn broadcast_concurrent(
    outputs: impl IntoIterator<Item = &mut BoxedOutput>,
    message: DispatcherMessage,
) -> StreamResult<()>

Concurrently broadcast a message to all outputs.

Note that this does not follow concurrent_dispatchers in the config and the concurrency is always unlimited.