Function echo_server_for_concurrency_test::run_echo_service

pub(crate) async fn run_echo_service(
    stream: EchoRequestStream,
    responders: Arc<Mutex<Vec<(EchoEchoStringResponder, Option<String>)>>>
)