@Override
    public CompletableFuture<Void> thenRun(Runnable action) {
        return future.thenRun(new DeserializingRunnable(serializationService, action));
    }
@Test
    public void test_actionsTrigger_whenAlreadyCompletedFuture() {
        CountDownLatch latch = new CountDownLatch(1);
        CompletableFuture<String> future =
                new DelegatingCompletableFuture<>(serializationService, newCompletedFuture("value"));
        future.thenRun(latch::countDown);
        assertOpenEventually(latch);
    }