fix(client-kinesis): support eventstream in subscribeToShard

[AllanZhengYP]

Issue

Fixes: #2131
Fixes: #2418
Related to: smithy-lang/smithy-typescript#573

Description

Codegen for upstream refactor to support event stream in RPC protocols.

Testing

Manual testing:

import {
  DescribeStreamCommand,
  KinesisClient,
  ListStreamConsumersCommand,
  RegisterStreamConsumerCommand,
  SubscribeToShardCommand,
} from "@aws-sdk/client-kinesis";

const client = new KinesisClient({});

const { StreamDescription } = await client.send(
  new DescribeStreamCommand({
    StreamName: "test-data-stream",
  })
);

const { StreamARN } = StreamDescription;

const { Consumers } = await client.send(
  new ListStreamConsumersCommand({
    StreamARN,
  })
);

console.log(Consumers);

let Consumer = Consumers.find((x) => x.ConsumerName == "tester");

if (Consumer == null) {
  const consumerData = await client.send(
    new RegisterStreamConsumerCommand({
      ConsumerName: "tester",
      StreamARN,
    })
  );
  Consumer = consumerData.Consumer;
}

console.log(`StreaARM: ${StreamARN}`);
console.log(`Consumer: ${Consumer.ConsumerARN}`);

const { EventStream } = await client.send(
  new SubscribeToShardCommand({
    ConsumerARN: Consumer.ConsumerARN,
    ShardId: "shardId-000000000000",
    StartingPosition: {
      Type: "LATEST",
    },
  })
);
console.log("Consuming");
for await (const event of EventStream) {
  console.log("EVENT", event);
}

TODO: merge #3810
TODO: add integration test for Kinesis::SubscribeToShard

---

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

[github-actions]

This thread has been automatically locked since there has not been any recent activity after it was closed. Please open a new issue for related bugs and link to relevant comments in this thread.