### Question:
DefaultExecutor extends AbstractOffloaderAwareExecutor implements Consumer<Runnable> { @Override public Cancellable schedule(final Runnable task, final long duration, final TimeUnit unit) { return scheduler.apply(task, duration, unit); } DefaultExecutor(int coreSize, int maxSize, ThreadFactory threadFactory);   DefaultExecutor(java.util.concurrent.Executor jdkExecutor);   DefaultExecutor(java.util.concurrent.Executor jdkExecutor, boolean interruptOnCancel);   DefaultExecutor(java.util.concurrent.Executor jdkExecutor, ScheduledExecutorService scheduler);   DefaultExecutor(java.util.concurrent.Executor jdkExecutor, ScheduledExecutorService scheduler,
                    boolean interruptOnCancel); private  DefaultExecutor(@Nullable java.util.concurrent.Executor jdkExecutor, @Nullable InternalScheduler scheduler,
                            boolean interruptOnCancel); @Override Cancellable execute(Runnable task); @Override Cancellable schedule(final Runnable task, final long duration, final TimeUnit unit); @Override SignalOffloader newSignalOffloader(final io.servicetalk.concurrent.Executor executor); @Override boolean hasThreadAffinity(); @Override void accept(final Runnable runnable);  }### Answer:
@Test public void scheduledTasks() throws Throwable { Task scheduled = new Task(); executor.schedule(scheduled, 1, MILLISECONDS); scheduled.awaitDone(); }
@Test public void rejectSchedule() { Executor executor = from(new RejectAllScheduler()); expected.expect(RejectedExecutionException.class); executor.schedule(() -> { }, 1, SECONDS); }