this.throttleMs = throttleMs;
        this.listener = listener;
        this.executor = executor;
        this.clock = clock;
        scheduleUpdateNow();
    }

    private void scheduleUpdateNow() {
        ScheduledFuture<?> ignored = executor.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                try {