feat: lambda_http body support for byte stream

Author: hugobast

rust-runtime/aws-smithy-http/Cargo.toml

@@ -29,6 +29,9 @@ tracing = "0.1"
 # We are using hyper for our streaming body implementation, but this is an internal detail.
 hyper = "0.14.12"
 
+# For support streaming lambda_http::Body
+lambda_http = "0.6.0"
+
 # ByteStream internals
 futures-core = "0.3.14"
 tokio = { version = "1.6", optional = true }

rust-runtime/aws-smithy-http/src/body.rs

@@ -250,6 +250,22 @@ impl From<hyper::Body> for SdkBody {
     }
 }
 
+impl From<lambda_http::Body> for SdkBody {
+    fn from(body: lambda_http::Body) -> Self {
+        let hyper_body = match body {
+            lambda_http::Body::Empty => hyper::Body::empty(),
+            lambda_http::Body::Text(s) => hyper::Body::from(s),
+            lambda_http::Body::Binary(v) => hyper::Body::from(v),
+        };
+
+        SdkBody {
+            inner: Inner::Streaming { inner: hyper_body },
+            rebuild: None,
+            callbacks: Vec::new(),
+        }
+    }
+}
+
 impl From<Vec<u8>> for SdkBody {
     fn from(data: Vec<u8>) -> Self {
         Self::from(Bytes::from(data))

rust-runtime/aws-smithy-http/src/byte_stream.rs

@@ -445,6 +445,12 @@ impl From<hyper::Body> for ByteStream {
     }
 }
 
+impl From<lambda_http::Body> for ByteStream {
+    fn from(input: lambda_http::Body) -> Self {
+        ByteStream::new(SdkBody::from(input))
+    }
+}
+
 #[derive(Debug)]
 pub struct Error(Box<dyn StdError + Send + Sync + 'static>);