feat: add kinesis stream support

gruntwork-io · Jun 10, 2022 · 90bae70 · 90bae70
1 parent 62d7e0c
commit 90bae70
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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 {