89 89 |
|
90 90 | cfg.store_put(::aws_smithy_runtime_api::client::auth::AuthSchemeOptionResolverParams::new(
|
91 91 | ::aws_smithy_runtime_api::client::auth::static_resolver::StaticAuthSchemeOptionResolverParams::new(),
|
92 92 | ));
|
93 93 |
|
94 94 | cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::SensitiveOutput);
|
95 95 | cfg.store_put(::aws_smithy_runtime_api::client::orchestrator::Metadata::new(
|
96 96 | "InvokeWithResponseStream",
|
97 97 | "lambda",
|
98 98 | ));
|
99 99 | let mut signing_options = ::aws_runtime::auth::SigningOptions::default();
|
100 100 | signing_options.double_uri_encode = true;
|
101 101 | signing_options.content_sha256_header = false;
|
102 102 | signing_options.normalize_uri_path = true;
|
103 103 | signing_options.payload_override = None;
|
104 104 |
|
105 105 | cfg.store_put(::aws_runtime::auth::SigV4OperationSigningConfig {
|
106 106 | signing_options,
|
107 107 | ..::std::default::Default::default()
|
108 108 | });
|
109 109 |
|
110 110 | ::std::option::Option::Some(cfg.freeze())
|
111 111 | }
|
112 112 |
|
113 113 | fn runtime_components(
|
114 114 | &self,
|
115 115 | _: &::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder,
|
116 116 | ) -> ::std::borrow::Cow<'_, ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder> {
|
117 117 | #[allow(unused_mut)]
|
118 118 | let mut rcb = ::aws_smithy_runtime_api::client::runtime_components::RuntimeComponentsBuilder::new("InvokeWithResponseStream")
|
119 + | .with_interceptor(::aws_smithy_runtime::client::stalled_stream_protection::StalledStreamProtectionInterceptor::default())
|
119 120 | .with_interceptor(InvokeWithResponseStreamEndpointParamsInterceptor)
|
120 121 | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::TransientErrorClassifier::<
|
121 122 | crate::operation::invoke_with_response_stream::InvokeWithResponseStreamError,
|
122 123 | >::new())
|
123 124 | .with_retry_classifier(::aws_smithy_runtime::client::retries::classifiers::ModeledAsRetryableClassifier::<
|
124 125 | crate::operation::invoke_with_response_stream::InvokeWithResponseStreamError,
|
125 126 | >::new())
|
126 127 | .with_retry_classifier(::aws_runtime::retries::classifiers::AwsErrorCodeClassifier::<
|
127 128 | crate::operation::invoke_with_response_stream::InvokeWithResponseStreamError,
|
128 129 | >::new());
|
129 130 |
|
130 131 | ::std::borrow::Cow::Owned(rcb)
|
131 132 | }
|
132 133 | }
|
133 134 |
|
134 135 | #[derive(Debug)]
|
135 136 | struct InvokeWithResponseStreamResponseDeserializer;
|
136 137 | impl ::aws_smithy_runtime_api::client::ser_de::DeserializeResponse for InvokeWithResponseStreamResponseDeserializer {
|
137 138 | fn deserialize_streaming(
|
138 139 | &self,
|
139 140 | response: &mut ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
|
140 141 | ) -> ::std::option::Option<::aws_smithy_runtime_api::client::interceptors::context::OutputOrError> {
|
141 142 | #[allow(unused_mut)]
|
142 143 | let mut force_error = false;
|
143 144 | ::tracing::debug!(request_id = ?::aws_types::request_id::RequestId::request_id(response));
|
144 145 |
|
145 146 | // If this is an error, defer to the non-streaming parser
|
146 147 | if (!response.status().is_success() && response.status().as_u16() != 200) || force_error {
|
147 148 | return ::std::option::Option::None;
|
148 149 | }
|