Try fix up - not working

Fuyang Liu · Fuyang Liu · commit c04d92fc61d9 · 2019-07-11T01:04:29.000+02:00
diff --git a/examples/echo.rs b/examples/echo.rs
@@ -6,6 +6,7 @@ extern crate hyper;
 use hyper::{Body, Method, Request, Response, Server, StatusCode};
 use hyper::service::{make_service_fn, service_fn};
 use futures_util::TryStreamExt;
+use futures_util::try_future::TryFutureExt;
 
 /// This is our service handler. It receives a Request, routes on its
 /// path, and returns a Future of a Response.
@@ -42,11 +43,13 @@ async fn echo(req: Request<Body>) -> Result<Response<Body>, hyper::Error> {
         // future, waiting on concatenating the full body, so that
         // it can be reversed. Only then can we return a `Response`.
         (&Method::POST, "/echo/reversed") => {
-            let reversed = req.into_body().concat2().map(move |chunk| {
+            let chunks = req.into_body().try_concat().await;
+
+            let reversed = chunks.map(move |chunk| {
                 let body = chunk.iter().rev().cloned().collect::<Vec<u8>>();
                 *response.body_mut() = Body::from(body);
                 response
-            });
+            })?;
 
             return Ok(reversed);
         }
