private void tick() {
        for (Listener listener : listeners) {
            listener.onTimeUpdated();
        }
    }
Listeners which are waiting for time changes.
s3stream/src/main/java/com/automq/stream/utils/MockTime.java