Minimum throughput body timeouts Pt.1

aws/sdk/integration-tests/s3/Cargo.toml

@@ -36,7 +36,8 @@ futures-util = { version = "0.3.16", default-features = false }
 hdrhistogram = "7.5.2"
 http = "0.2.3"
 http-body = "0.4.5"
-hyper = "0.14.26"
+hyper = { version = "0.14.26", features = ["stream"] }
+once_cell = "1.18.0"
 pretty_assertions = "1.3"
 serde_json = "1"
 smol = "1.2"

rust-runtime/Cargo.toml

@@ -1,6 +1,4 @@
 [workspace]
-
-
 members = [
     "inlineable",
     "aws-smithy-async",

rust-runtime/aws-smithy-async/src/future/pagination_stream.rs

@@ -184,11 +184,11 @@ mod test {
         // `tokio_test::task::Spawn::poll_next` can only be invoked when the wrapped
         // type implements the `Stream` trait. Here, `FnStream` does not implement it,
         // so we work around it by using the `enter` method.
-        let _ = test_stream.enter(|ctx, pin| {
+        test_stream.enter(|ctx, pin| {
             let polled = pin.poll_next(ctx);
             assert!(polled.is_pending());
         });
-        let _ = test_stream.enter(|ctx, pin| {
+        test_stream.enter(|ctx, pin| {
             let polled = pin.poll_next(ctx);
             assert!(polled.is_pending());
         });

rust-runtime/aws-smithy-async/src/rt/sleep.rs

@@ -83,7 +83,7 @@ pub fn default_async_sleep() -> Option<SharedAsyncSleep> {
 /// Future returned by [`AsyncSleep`].
 #[non_exhaustive]
 #[must_use]
-pub struct Sleep(Pin<Box<dyn Future<Output = ()> + Send + 'static>>);
+pub struct Sleep(Pin<Box<dyn Future<Output = ()> + Send + Sync + 'static>>);
 
 impl Debug for Sleep {
     fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
@@ -95,7 +95,7 @@ impl Sleep {
     /// Create a new [`Sleep`] future
     ///
     /// The provided future will be Boxed.
-    pub fn new(future: impl Future<Output = ()> + Send + 'static) -> Sleep {
+    pub fn new(future: impl Future<Output = ()> + Send + Sync + 'static) -> Sleep {
         Sleep(Box::pin(future))
     }
 }

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

@@ -12,7 +12,7 @@ repository = "https://github.com/awslabs/smithy-rs"
 [features]
 client = ["aws-smithy-runtime-api/client"]
 http-auth = ["aws-smithy-runtime-api/http-auth"]
-connector-hyper-0-14-x = ["dep:hyper", "hyper?/client", "hyper?/http2", "hyper?/http1", "hyper?/tcp"]
+connector-hyper-0-14-x = ["dep:hyper", "hyper?/client", "hyper?/http2", "hyper?/http1", "hyper?/tcp", "hyper?/stream"]
 tls-rustls = ["dep:hyper-rustls", "dep:rustls", "connector-hyper-0-14-x"]
 rt-tokio = ["tokio/rt"]
 
@@ -47,6 +47,8 @@ approx = "0.5.1"
 aws-smithy-async = { path = "../aws-smithy-async", features = ["rt-tokio", "test-util"] }
 aws-smithy-runtime-api = { path = "../aws-smithy-runtime-api", features = ["test-util"] }
 aws-smithy-types = { path = "../aws-smithy-types", features = ["test-util"] }
+futures-util = "0.3.28"
+pretty_assertions = "1.4.0"
 tokio = { version = "1.25", features = ["macros", "rt", "rt-multi-thread", "test-util"] }
 tracing-subscriber = { version = "0.3.16", features = ["env-filter"] }
 tracing-test = "0.2.1"

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

@@ -15,3 +15,6 @@ pub mod test_util;
 /// needing to provide equivalent functionality for hyper 1.x in the future.
 #[cfg(feature = "connector-hyper-0-14-x")]
 pub mod hyper_014;
+
+/// HTTP body and body-wrapper types
+pub mod body;

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

@@ -0,0 +1,6 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+pub mod minimum_throughput;