From 317edd71d3373a04a86a8bf6d16b800818adddf9 Mon Sep 17 00:00:00 2001 From: Zach Humpherys Date: Wed, 21 Feb 2024 11:05:16 -0800 Subject: [PATCH] Changed names of unit tests to reflect new behavior --- .../retrieval/polling/PrefetchRecordsPublisherTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisherTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisherTest.java index 278c3fdf..aeacab8e 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisherTest.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisherTest.java @@ -378,14 +378,14 @@ public class PrefetchRecordsPublisherTest { } @Test(expected = IllegalStateException.class) - public void testGetNextRecordsWithoutStarting() { + public void testSubscribeWithoutStarting() { verify(executorService, never()).execute(any()); Subscriber mockSubscriber = mock(Subscriber.class); getRecordsCache.subscribe(mockSubscriber); } @Test(expected = IllegalStateException.class) - public void testCallAfterShutdown() { + public void testRequestRecordsOnSubscriptionAfterShutdown() { GetRecordsResponse response = GetRecordsResponse.builder().records( Record.builder().data(SdkBytes.fromByteArray(new byte[] { 1, 2, 3 })).sequenceNumber("123").build()) .nextShardIterator(NEXT_SHARD_ITERATOR).build();