Function write_all

pulse-proxy/src/test/integration/mod.rs:94–98

(stream: &mut TcpStream, lines: &[&str])

}

async fn write_all(stream: &mut TcpStream, lines: &[&str]) {
  for line in lines {
    stream.write_all(line.as_bytes()).await.unwrap();
  }
}

async fn make_admin_request(addr: SocketAddr, path: &str) -> String {
  let client = Client::builder(TokioExecutor::new()).build_http::<Empty<Bytes>>();