Skip to content

ListStreamConsumers

Source: src/AWS/Kinesis/ListStreamConsumers.ts

Runtime binding for kinesis:ListStreamConsumers.

Bind this operation to a Stream to enumerate the enhanced fan-out consumers registered on it — the stream ARN is injected automatically. Provide the implementation with Effect.provide(AWS.Kinesis.ListStreamConsumersHttp).

// init
const listStreamConsumers = yield* AWS.Kinesis.ListStreamConsumers(stream);
// runtime
const result = yield* listStreamConsumers();
const names = (result.Consumers ?? []).map((c) => c.ConsumerName);