Method flush

future-java/src/main/java/io/trane/future/Promise.java:878–890

(final Future<T> result)

  }

  @SuppressWarnings("unchecked")
  @Override
  public final void flush(final Future<T> result) {
    Future<Object> r = (Future<Object>) result;
    WaitQueue<Object> q = (Continuation<Object, Object>) this;
    while (q instanceof Continuation) {
      final Continuation<Object, Object> c = (Continuation<Object, Object>) q;
      r = c.apply(r);
      q = c.safeFlush(r);
    }
    if (q != null)
      q.flush(r);
  }

  abstract Future<R> apply(Future<T> result);