SynchronousTestExecutor.java

package io.getunleash;

import io.getunleash.util.UnleashScheduledExecutor;
import java.util.concurrent.Delayed;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class SynchronousTestExecutor implements UnleashScheduledExecutor {

    private static final Logger LOG = LoggerFactory.getLogger(SynchronousTestExecutor.class);

    @Override
    public void setInterval(Runnable command, long initialDelaySec, long periodSec)
            throws RejectedExecutionException {
        LOG.warn("i will only do this once");
        scheduleOnce(command);
    }

    @Override
    public ScheduledFuture<Void> scheduleOnce(Runnable runnable) {
        runnable.run();
        return new AlreadyCompletedScheduledFuture();
    }

    private static class AlreadyCompletedScheduledFuture implements ScheduledFuture<Void> {
        @Override
        public long getDelay(TimeUnit timeUnit) {
            return 0;
        }

        @Override
        public int compareTo(Delayed delayed) {
            return 0;
        }

        @Override
        public boolean cancel(boolean b) {
            return false;
        }

        @Override
        public boolean isCancelled() {
            return false;
        }

        @Override
        public boolean isDone() {
            return false;
        }

        @Override
        public Void get() {
            return null;
        }

        @Override
        public Void get(long l, TimeUnit timeUnit) {
            return null;
        }
    }
}