### Question:
PendingAsyncOperations { void add(Address owningAddress, long futureId, Message message) { Map<Long, Message> asyncOps = memoryStore.computeIfAbsent(owningAddress, unused -> new HashMap<>()); asyncOps.put(futureId, message); } @Inject  PendingAsyncOperations(
      @Label("state") State state,
      @Label("async-operations") MapState<Long, Message> backingStore); @VisibleForTesting  PendingAsyncOperations(Consumer<Address> keySetter, MapState<Long, Message> backingStore);   }### Answer:
@Test public void itemsAreExplicitlyFlushed() { PendingAsyncOperations pendingOps = new PendingAsyncOperations(miniStateBackend, miniStateBackend); miniStateBackend.setCurrentAddress(FUNCTION_1_ADDR); pendingOps.add(FUNCTION_1_ADDR, 1, dummyMessage); assertThat(miniStateBackend, not(matchesAddressState(FUNCTION_1_ADDR, hasKey(1L)))); }