Method respond

future-java/src/main/java/io/trane/future/Promise.java:702–713

(final Responder<? super T> r)

  }

  @Override
  public final Future<T> respond(final Responder<? super T> r) {
    if (getInterruptHandler() != null)
      return continuation(new Respond<T>(r) {
        @Override
        protected final InterruptHandler getInterruptHandler() {
          return Promise.this;
        }
      });
    else
      return continuation(new Respond<T>(r));
  }

  private static class Rescue<T> extends Continuation<T, T> {
    private final Function<Throwable, ? extends Future<T>> f;