@Override
    public ScheduledExecutor getScheduledExecutor() {
        return internalScheduledExecutor;
    }
@Test
    void testScheduleRunnable() throws Exception {
        final OneShotLatch latch = new OneShotLatch();
        final long delay = 100L;
        final long start = System.nanoTime();

        ScheduledFuture<?> scheduledFuture =
                pekkoRpcService
                        .getScheduledExecutor()
                        .schedule(latch::trigger, delay, TimeUnit.MILLISECONDS);

        scheduledFuture.get();

        assertThat(latch.isTriggered()).isTrue();
        final long stop = System.nanoTime();

        assertThat(((stop - start) / 1000000))
                .as("call was not properly delayed")
                .isGreaterThanOrEqualTo(delay);
    }