Class WithinPromise

future-java/src/main/java/io/trane/future/Promise.java:799–834

  }

  private static final class WithinPromise<T> extends Promise<T> implements Responder<T>, Runnable {

    private final InterruptHandler handler;
    private final ScheduledFuture<?> task;
    private final Throwable exception;

    public WithinPromise(final InterruptHandler handler, final Duration timeout,
        final ScheduledExecutorService scheduler, final Throwable exception) {
      this.handler = handler;
      this.task = scheduler.schedule(this, timeout.toMillis(), TimeUnit.MILLISECONDS);
      this.exception = exception;
    }

    @Override
    public final void onException(final Throwable ex) {
      task.cancel(false);
      becomeIfEmpty(Future.exception(ex));
    }

    @Override
    public final void onValue(final T value) {
      task.cancel(false);
      becomeIfEmpty(Future.value(value));
    }

    @Override
    public final void run() {
      handler.raise(exception);
      becomeIfEmpty(Future.exception(exception));
    }

    @Override
    protected final InterruptHandler getInterruptHandler() {
      return handler;
    }
  }

  @Override
  public final Future<T> within(final Duration timeout, final ScheduledExecutorService scheduler,