Class JoinPromise

future-java/src/main/java/io/trane/future/Future.java:643–667

}

final class JoinPromise<T> extends Promise<Void> implements Responder<T> {
  private final AtomicInteger count;
  private final List<? extends Future<T>> list;

  public JoinPromise(final List<? extends Future<T>> list) {
    this.list = list;
    this.count = new AtomicInteger(list.size());
  }

  @Override
  public final void onException(final Throwable ex) {
    setException(ex);
  }

  @Override
  public final void onValue(final T value) {
    if (count.decrementAndGet() == 0)
      become(Future.VOID);
  }

  @Override
  protected InterruptHandler getInterruptHandler() {
    return InterruptHandler.apply(list);
  }
}

final class FirstCompletedOfPromise<T> extends Promise<T> implements Responder<T> {