RefDataOnHeapStore extends AbstractRefDataStore { @Override public boolean isDataLoaded(final RefStreamDefinition refStreamDefinition) { final boolean isDataLoaded = Optional.ofNullable(processingInfoMap.get(refStreamDefinition)) .filter(processingInfo -> processingInfo.getProcessingState().equals(ProcessingState.COMPLETE)) .isPresent(); LOGGER.trace("isDataLoaded({}) returning {}", refStreamDefinition, isDataLoaded); return isDataLoaded; } RefDataOnHeapStore(); @Override StorageType getStorageType(); @Override Optional<RefDataProcessingInfo> getAndTouchProcessingInfo(final RefStreamDefinition refStreamDefinition); @Override boolean isDataLoaded(final RefStreamDefinition refStreamDefinition); @Override boolean exists(final MapDefinition mapDefinition); @Override Optional<RefDataValue> getValue(final MapDefinition mapDefinition, final String key); @Override boolean consumeValueBytes(final MapDefinition mapDefinition,
                                     final String key,
                                     final Consumer<TypedByteBuffer> valueBytesConsumer); @Override List<RefStoreEntry> list(final int limit); @Override List<RefStoreEntry> list(final int limit,
                                    final Predicate<RefStoreEntry> filter); @Override long getKeyValueEntryCount(); @Override long getKeyRangeValueEntryCount(); @Override long getProcessingInfoEntryCount(); @Override void purgeOldData(); @Override void logAllContents(); @Override void logAllContents(final Consumer<String> logEntryConsumer);  }
@Test void isDataLoaded_false() { final RefStreamDefinition refStreamDefinition = buildUniqueRefStreamDefinition(); boolean isLoaded = refDataStore.isDataLoaded(refStreamDefinition); assertThat(isLoaded).isFalse(); }