Class CollectPromise

future-java/src/main/java/io/trane/future/Future.java:617–641

}

final class CollectPromise<T> extends Promise<List<T>> {

  private final Object[] results;
  private final AtomicInteger count;
  private final List<? extends Future<T>> list;

  public CollectPromise(final List<? extends Future<T>> list) {
    final int size = list.size();
    this.results = new Object[size];
    this.count = new AtomicInteger(size);
    this.list = list;
  }

  @SuppressWarnings("unchecked")
  public final void collect(final T value, final int i) {
    results[i] = value;
    if (count.decrementAndGet() == 0)
      setValue((List<T>) Arrays.asList(results));
  }

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

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