diff --git a/src/main/java/com/mathieubolla/guava/ParallelUtils.java b/src/main/java/com/mathieubolla/guava/ParallelUtils.java index ebc76f6..d806186 100644 --- a/src/main/java/com/mathieubolla/guava/ParallelUtils.java +++ b/src/main/java/com/mathieubolla/guava/ParallelUtils.java @@ -44,14 +44,14 @@ public static Iterable parallelFilter(Iterable source, Predicate pr return doFilterStuf(source, predicate, factor, executorService, true); } - private static Iterable doTransformStuf(final Iterable source, final Function transform, int factor, final ExecutorService executorService, final boolean shutdownInTheEnd) { + private static Iterable doTransformStuf(final Iterable source, final Function transform, final int factor, final ExecutorService executorService, final boolean shutdownInTheEnd) { Preconditions.checkArgument(factor > 0, "You should really be using strictly positive factors when doing parallel computing"); - final LinkedBlockingQueue> queue = new LinkedBlockingQueue>(factor); - final Iterator sourceIterator = source.iterator(); - return new Iterable() { public Iterator iterator() { + final LinkedBlockingQueue> queue = new LinkedBlockingQueue>(factor); + final Iterator sourceIterator = source.iterator(); + return new AbstractIterator() { @Override protected U computeNext() {