From 90bae70a15d0d07318085e8d7fbf54040b941abd Mon Sep 17 00:00:00 2001 From: Taliesin Millhouse Date: Fri, 10 Jun 2022 15:32:57 +1000 Subject: [PATCH] feat: add kinesis stream support --- aws/kinesis_stream_test.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/aws/kinesis_stream_test.go b/aws/kinesis_stream_test.go index bc35b56e..b19067ff 100644 --- a/aws/kinesis_stream_test.go +++ b/aws/kinesis_stream_test.go @@ -53,6 +53,8 @@ func TestNukeKinesisStreamOne(t *testing.T) { t, nukeAllKinesisStreams(session, identifiers), ) + + assertKinesisStreamsDeleted(t, svc, identifiers) } func TestNukeKinesisStreamMoreThanOne(t *testing.T) { @@ -77,6 +79,8 @@ func TestNukeKinesisStreamMoreThanOne(t *testing.T) { t, nukeAllKinesisStreams(session, sNames), ) + + assertKinesisStreamsDeleted(t, svc, sNames) } func createKinesisStream(t *testing.T, svc *kinesis.Kinesis) *string {