Skip to content

Commit 7d9ae68

Browse files
committed
chore(client-kinesis): switch to H2 handler and integration test
1 parent 87fd581 commit 7d9ae68

File tree

3 files changed

+21
-2
lines changed

3 files changed

+21
-2
lines changed
Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
module.exports = {
2+
preset: "ts-jest",
3+
testMatch: ["**/*.integ.spec.ts"],
4+
};

clients/client-kinesis/src/runtimeConfig.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ import {
1717
NODE_RETRY_MODE_CONFIG_OPTIONS,
1818
} from "@aws-sdk/middleware-retry";
1919
import { loadConfig as loadNodeConfig } from "@aws-sdk/node-config-provider";
20-
import { NodeHttpHandler as RequestHandler, streamCollector } from "@aws-sdk/node-http-handler";
20+
import { NodeHttp2Handler, streamCollector } from "@aws-sdk/node-http-handler";
2121
import { fromBase64, toBase64 } from "@aws-sdk/util-base64-node";
2222
import { calculateBodyLength } from "@aws-sdk/util-body-length-node";
2323
import { defaultUserAgent } from "@aws-sdk/util-user-agent-node";
@@ -50,7 +50,7 @@ export const getRuntimeConfig = (config: KinesisClientConfig) => {
5050
eventStreamSerdeProvider: config?.eventStreamSerdeProvider ?? eventStreamSerdeProvider,
5151
maxAttempts: config?.maxAttempts ?? loadNodeConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS),
5252
region: config?.region ?? loadNodeConfig(NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS),
53-
requestHandler: config?.requestHandler ?? new RequestHandler(defaultConfigProvider),
53+
requestHandler: config?.requestHandler ?? new NodeHttp2Handler(),
5454
retryMode:
5555
config?.retryMode ??
5656
loadNodeConfig({
Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
import { KinesisClient, ListStreamsCommand } from "../src/index";
2+
3+
describe("@aws-sdk/client-kinesis", () => {
4+
const client = new KinesisClient({});
5+
const ONE_SECOND = 1 * 1000;
6+
7+
it(
8+
`${ListStreamsCommand.name} should succeed`,
9+
async () => {
10+
const { StreamNames } = await client.send(new ListStreamsCommand({}));
11+
expect(StreamNames).toBeInstanceOf(Array);
12+
},
13+
ONE_SECOND
14+
);
15+
});

0 commit comments

Comments
 (0)