### Question:
LocalJobStore extends JobStoreWithValidator { @Override public Map<String, Integer> getCounts(UUID jobId) { return counts.computeIfAbsent(jobId, k -> new ConcurrentHashMap<>()); } LocalJobStore();  LocalJobStore(Monitor monitor); @Override void createJob(UUID jobId, PortabilityJob job); @Override void updateJob(UUID jobId, PortabilityJob job); @Override void addErrorsToJob(UUID jobId, Collection<ErrorDetail> errors); @Override void remove(UUID jobId); @Override PortabilityJob findJob(UUID jobId); @Override synchronized UUID findFirst(JobAuthorization.State jobState); @Override void addCounts(UUID jobId, Map<String, Integer> newCounts); @Override Map<String, Integer> getCounts(UUID jobId); @Override void addBytes(UUID jobId, Long bytes); @Override Long getBytes(UUID jobId); @Override void create(UUID jobId, String key, T model); @Override void update(UUID jobId, String key, T model); @Override T findData(UUID jobId, String key, Class<T> type); @Override void create(UUID jobId, String key, InputStream stream); @Override InputStreamWrapper getStream(UUID jobId, String key);  }### Answer:
@Test public void canAddNewKeysToTheCurrentCountsTest() { addItemToJobStoreCounts(ITEM_NAME); final Map<String, Integer> counts = localJobStore.getCounts(jobId); Truth.assertThat(counts.size()).isEqualTo(1); Truth.assertThat(counts.get(ITEM_NAME)).isEqualTo(1); }
@Test public void canAddExistingKeysToCurrentCountsTest() { addItemToJobStoreCounts(ITEM_NAME); addItemToJobStoreCounts(ITEM_NAME); final Map<String, Integer> counts = localJobStore.getCounts(jobId); Truth.assertThat(counts.size()).isEqualTo(1); Truth.assertThat(counts.get(ITEM_NAME)).isEqualTo(2); }