luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Changed names of unit tests to reflect new behavior

Browse source
This commit is contained in:
Zach Humpherys 2024-02-21 11:05:16 -08:00
parent d479d79925
commit 317edd71d3
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisherTest.java
View file

@ -378,14 +378,14 @@ public class PrefetchRecordsPublisherTest {
} }
@Test(expected = IllegalStateException.class) @Test(expected = IllegalStateException.class)
public void testGetNextRecordsWithoutStarting() { public void testSubscribeWithoutStarting() {
verify(executorService, never()).execute(any()); verify(executorService, never()).execute(any());
Subscriber<RecordsRetrieved> mockSubscriber = mock(Subscriber.class); Subscriber<RecordsRetrieved> mockSubscriber = mock(Subscriber.class);
getRecordsCache.subscribe(mockSubscriber); getRecordsCache.subscribe(mockSubscriber);
} }
@Test(expected = IllegalStateException.class) @Test(expected = IllegalStateException.class)
public void testCallAfterShutdown() { public void testRequestRecordsOnSubscriptionAfterShutdown() {
GetRecordsResponse response = GetRecordsResponse.builder().records( GetRecordsResponse response = GetRecordsResponse.builder().records(
Record.builder().data(SdkBytes.fromByteArray(new byte[] { 1, 2, 3 })).sequenceNumber("123").build()) Record.builder().data(SdkBytes.fromByteArray(new byte[] { 1, 2, 3 })).sequenceNumber("123").build())
.nextShardIterator(NEXT_SHARD_ITERATOR).build(); .nextShardIterator(NEXT_SHARD_ITERATOR).build();