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 {