Kinesis Stream type-safe Integration class

[sam-goodwin]

Provide a wrapper class, Stream<T>, that models the Kinesis Stream Functionless integrations.

Must integrates with the following:

1. AppSync

const stream = new Stream<string>(new aws_sqs.Stream(..))

new AppsyncResolver<{id: string}>($context => {
  stream.putRecord({
    Data: id,
    PartitionKey: id
  });
});

2. Step Functions

new StepFunction(scope, id, (id: string) => {
  stream.sendMessage({
    Data: id,
    PartitionKey: id
  })
})

3. Event Bridge

bus
  .when(scope, "rule", event => event.source === "lambda")
  .map(event => event.record)
  .pipe(stream)