Package org.eclipse.collections.impl.lazy.parallel.list

Class ParallelFlatCollectListIterable<T,V>

java.lang.Object

org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>

org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable<V,ListBatch<V>>

org.eclipse.collections.impl.lazy.parallel.list.ParallelFlatCollectListIterable<T,V>

All Implemented Interfaces:

ParallelListIterable<V>, ParallelIterable<V>

public class ParallelFlatCollectListIterable<T,V>
extends AbstractParallelListIterable<V,ListBatch<V>>

Field Summary

Fields

Modifier and Type	Field	Description
private Function<? super T,? extends java.lang.Iterable<V>>	function
private AbstractParallelIterable<T,? extends OrderedBatch<T>>	parallelIterable

Constructor Summary

Constructors

Constructor	Description
ParallelFlatCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable, Function<? super T,? extends java.lang.Iterable<V>> function)

Method Summary

Modifier and Type	Method	Description
boolean	allSatisfy(Predicate<? super V> predicate)
boolean	anySatisfy(Predicate<? super V> predicate)
V	detect(Predicate<? super V> predicate)
void	forEach(Procedure<? super V> procedure)
int	getBatchSize()
java.util.concurrent.ExecutorService	getExecutorService()
LazyIterable<ListBatch<V>>	split()

Methods inherited from class org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable

asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, groupByUniqueKey, isOrdered, reject, rejectWith, select, selectInstancesOf, selectWith, toArray, toArray

Methods inherited from class org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable

aggregateBy, aggregateInPlaceBy, allSatisfy, allSatisfyWith, anySatisfy, anySatisfyWith, appendString, collectCombine, count, countWith, detect, detectIfNone, detectWith, detectWithIfNone, forEach, forEachWith, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toBag, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.collections.api.ParallelIterable

aggregateBy, aggregateInPlaceBy, allSatisfyWith, anySatisfyWith, appendString, appendString, appendString, count, countWith, detectIfNone, detectWith, detectWithIfNone, forEachWith, makeString, makeString, makeString, makeString, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toBag, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy

Field Detail

parallelIterable

private final AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable

function

private final Function<? super T,? extends java.lang.Iterable<V>> function

Constructor Detail

ParallelFlatCollectListIterable

public ParallelFlatCollectListIterable(AbstractParallelIterable<T,? extends OrderedBatch<T>> parallelIterable,
                                       Function<? super T,? extends java.lang.Iterable<V>> function)

Method Detail

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

Specified by:

getExecutorService in class AbstractParallelIterable<V,ListBatch<V>>

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in class AbstractParallelIterable<V,ListBatch<V>>

split

public LazyIterable<ListBatch<V>> split()

Specified by:

split in class AbstractParallelIterable<V,ListBatch<V>>

forEach

public void forEach(Procedure<? super V> procedure)

detect

public V detect(Predicate<? super V> predicate)

anySatisfy

public boolean anySatisfy(Predicate<? super V> predicate)

allSatisfy

public boolean allSatisfy(Predicate<? super V> predicate)