@Test public void testGetResults() { assertTrue(collector.getResults().isEmpty()); }
@Override public Collection<FastFuture<T>> getResults() { active.stream() .forEach(cf -> safeJoin.apply(cf)); active.clear(); return new ArrayList<>(); }
EmptyCollector implements LazyResultConsumer<T> { @Override public Collection<FastFuture<T>> getResults() { active.stream() .forEach(cf -> safeJoin.apply(cf)); active.clear(); return new ArrayList<>(); } }
EmptyCollector implements LazyResultConsumer<T> { @Override public Collection<FastFuture<T>> getResults() { active.stream() .forEach(cf -> safeJoin.apply(cf)); active.clear(); return new ArrayList<>(); } EmptyCollector(); }
EmptyCollector implements LazyResultConsumer<T> { @Override public Collection<FastFuture<T>> getResults() { active.stream() .forEach(cf -> safeJoin.apply(cf)); active.clear(); return new ArrayList<>(); } EmptyCollector(); @Override void accept(final FastFuture<T> t); void add(final FastFuture<T> t); @Override EmptyCollector<T> withResults(final Collection<FastFuture<T>> t); @Override void block(final Function<FastFuture<T>, T> safeJoin); void afterResults(Runnable r); @Override Collection<FastFuture<T>> getResults(); @Override Collection<FastFuture<T>> getAllResults(); boolean hasCapacity(final int i); }
EmptyCollector implements LazyResultConsumer<T> { @Override public Collection<FastFuture<T>> getResults() { active.stream() .forEach(cf -> safeJoin.apply(cf)); active.clear(); return new ArrayList<>(); } EmptyCollector(); @Override void accept(final FastFuture<T> t); void add(final FastFuture<T> t); @Override EmptyCollector<T> withResults(final Collection<FastFuture<T>> t); @Override void block(final Function<FastFuture<T>, T> safeJoin); void afterResults(Runnable r); @Override Collection<FastFuture<T>> getResults(); @Override Collection<FastFuture<T>> getAllResults(); boolean hasCapacity(final int i);  }