@Override
    public long get(K key) {
        return complete(asyncCounterMap.get(key));
    }
@Test(expected = ConsistentMapException.Interrupted.class)
    public void testInterrupted() {
        AtomicCounterMapWithErrors<String> atomicCounterMap =
                new AtomicCounterMapWithErrors<>();
        atomicCounterMap.setErrorState(TestingCompletableFutures.ErrorState.INTERRUPTED_EXCEPTION);
        DefaultAtomicCounterMap<String> map =
                new DefaultAtomicCounterMap<>(atomicCounterMap, 1000);

        map.get(KEY1);
    }