Adding upstream version 115.7.0esr.upstream/115.7.0esrupstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 52 insertions, 0 deletions

diff --git a/third_party/rust/h2/examples/client.rs b/third_party/rust/h2/examples/client.rs
new file mode 100644
index 0000000000..61e237aa3c
--- /dev/null
+++ b/third_party/rust/h2/examples/client.rs
@@ -0,0 +1,52 @@
+use h2::client;
+use http::{HeaderMap, Request};
+
+use std::error::Error;
+
+use tokio::net::TcpStream;
+
+#[tokio::main]
+pub async fn main() -> Result<(), Box<dyn Error>> {
+    let _ = env_logger::try_init();
+
+    let tcp = TcpStream::connect("127.0.0.1:5928").await?;
+    let (mut client, h2) = client::handshake(tcp).await?;
+
+    println!("sending request");
+
+    let request = Request::builder()
+        .uri("https://http2.akamai.com/")
+        .body(())
+        .unwrap();
+
+    let mut trailers = HeaderMap::new();
+    trailers.insert("zomg", "hello".parse().unwrap());
+
+    let (response, mut stream) = client.send_request(request, false).unwrap();
+
+    // send trailers
+    stream.send_trailers(trailers).unwrap();
+
+    // Spawn a task to run the conn...
+    tokio::spawn(async move {
+        if let Err(e) = h2.await {
+            println!("GOT ERR={:?}", e);
+        }
+    });
+
+    let response = response.await?;
+    println!("GOT RESPONSE: {:?}", response);
+
+    // Get the body
+    let mut body = response.into_body();
+
+    while let Some(chunk) = body.data().await {
+        println!("GOT CHUNK = {:?}", chunk?);
+    }
+
+    if let Some(trailers) = body.trailers().await? {
+        println!("GOT TRAILERS: {:?}", trailers);
+    }
+
+    Ok(())
+}