fix(transcirbe-streaming): set max concurrenccy to 1 (#2563)

aws · Jul 9, 2021 · fb42522 · fb42522
1 parent 9303bf7
commit fb42522
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/clients/client-transcribe-streaming/runtimeConfig.ts b/clients/client-transcribe-streaming/runtimeConfig.ts
@@ -34,7 +34,7 @@ export const ClientDefaultValues: Required<ClientDefaults> = {
   eventStreamSerdeProvider,
   maxAttempts: loadNodeConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS),
   region: loadNodeConfig(NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS),
-  requestHandler: new NodeHttp2Handler(),
+  requestHandler: new NodeHttp2Handler({ disableConcurrentStreams: true }),
   retryModeProvider: loadNodeConfig(NODE_RETRY_MODE_CONFIG_OPTIONS),
   sha256: Hash.bind(null, "sha256"),
   streamCollector,

diff --git a/.../java/software/amazon/smithy/aws/typescript/codegen/AddTranscribeStreamingDependency.java b/.../java/software/amazon/smithy/aws/typescript/codegen/AddTranscribeStreamingDependency.java
@@ -24,6 +24,7 @@
 import software.amazon.smithy.model.Model;
 import software.amazon.smithy.model.shapes.ServiceShape;
 import software.amazon.smithy.typescript.codegen.LanguageTarget;
+import software.amazon.smithy.typescript.codegen.TypeScriptDependency;
 import software.amazon.smithy.typescript.codegen.TypeScriptSettings;
 import software.amazon.smithy.typescript.codegen.TypeScriptWriter;
 import software.amazon.smithy.typescript.codegen.integration.RuntimeClientPlugin;
@@ -76,6 +77,14 @@ public Map<String, Consumer<TypeScriptWriter>> getRuntimeConfigWriters(
                 });
 
         switch (target) {
+            case NODE:
+                return MapUtils.of(
+                    "requestHandler", writer -> {
+                        writer.addDependency(TypeScriptDependency.AWS_SDK_NODE_HTTP_HANDLER);
+                        writer.addImport("NodeHttp2Handler", "NodeHttp2Handler",
+                            TypeScriptDependency.AWS_SDK_NODE_HTTP_HANDLER.packageName);
+                         writer.write("requestHandler: new NodeHttp2Handler({ disableConcurrentStreams: true }),");
+                    });
             case REACT_NATIVE:
             case BROWSER:
                 return transcribeStreamingHandlerConfig;