### Question:
TimestampedKeyValueGetAllQuery implements LocalStoreQuery<K, V> { @Override public Try<List<KV<K, V>>> execute(final KafkaStreamsContainer container, final long limit) { final LocalStoreAccessor<ReadOnlyKeyValueStore<K, ValueAndTimestamp<V>>> accessor = container.localTimestampedKeyValueStore(storeName); final Reader<ReadOnlyKeyValueStore<K, ValueAndTimestamp<V>>, List<KV<K, V>>> reader = reader().map(iterator -> LocalStoreQuery.toKeyValueAndTimestampListAndClose(iterator, limit)); return new LocalStoreQueryExecutor<>(accessor).execute(reader); } TimestampedKeyValueGetAllQuery(final String storeName); @Override StoreType storeType(); @Override StoreOperation operationType(); @Override Try<List<KV<K, V>>> execute(final KafkaStreamsContainer container, final long limit);  }### Answer:
@Test public void shouldGetAll() { TimestampedKeyValueGetAllQuery<String, String> query = new TimestampedKeyValueGetAllQuery<>(STORE_NAME); final var mkContainer = Mockito.mock(KafkaStreamsContainer.class); ReadOnlyKeyValueStore store = mock(ReadOnlyKeyValueStore.class); when(store.all()).thenReturn(new InMemoryKeyValueIterator<>("key", ValueAndTimestamp.make("value", 1L))); when(mkContainer.localTimestampedKeyValueStore(matches(STORE_NAME))).thenReturn(new LocalStoreAccessor<>(() -> store)); Try<List<KV<String, String>>> result = query.execute(mkContainer); Assertions.assertEquals(1, result.get().size()); Assertions.assertEquals(KV.of("key", "value", 1L), result.get().get(0)); }