@Test public void testWithResults() { collector = collector.withMaxActive(new MaxActive(4,3)); assertThat(collector.withResults(null).getMaxActive().getMaxActive(),is(4)); }
@Override public EmptyCollector<T> withResults(final Collection<FastFuture<T>> t) { return this.withMaxActive(maxActive); }
EmptyCollector implements LazyResultConsumer<T> { @Override public EmptyCollector<T> withResults(final Collection<FastFuture<T>> t) { return this.withMaxActive(maxActive); } }
EmptyCollector implements LazyResultConsumer<T> { @Override public EmptyCollector<T> withResults(final Collection<FastFuture<T>> t) { return this.withMaxActive(maxActive); } EmptyCollector(); }
EmptyCollector implements LazyResultConsumer<T> { @Override public EmptyCollector<T> withResults(final Collection<FastFuture<T>> t) { return this.withMaxActive(maxActive); } 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 EmptyCollector<T> withResults(final Collection<FastFuture<T>> t) { return this.withMaxActive(maxActive); } 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);  }