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

Class AbstractParallelListIterable<T,B extends ListBatch<T>>

java.lang.Object

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

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

All Implemented Interfaces:

ParallelListIterable<T>, ParallelIterable<T>

Direct Known Subclasses:

ListIterableParallelIterable, ParallelCollectListIterable, ParallelFlatCollectListIterable, ParallelSelectListIterable

public abstract class AbstractParallelListIterable<T,B extends ListBatch<T>>
extends AbstractParallelIterable<T,B>
implements ParallelListIterable<T>

Constructor Summary

Constructors

Constructor	Description
AbstractParallelListIterable()

Method Summary

Modifier and Type	Method	Description
ParallelUnsortedSetIterable<T>	asUnique()
<V> ParallelListIterable<V>	collect(Function<? super T,? extends V> function)	Creates a parallel iterable for collecting elements from the current iterable.
<V> ParallelListIterable<V>	collectIf(Predicate<? super T> predicate, Function<? super T,? extends V> function)	Creates a parallel iterable for selecting and collecting elements from the current iterable.
<P,V> ParallelListIterable<V>	collectWith(Function2<? super T,? super P,? extends V> function, P parameter)
<V> ParallelListIterable<V>	flatCollect(Function<? super T,? extends java.lang.Iterable<V>> function)	Creates a parallel flattening iterable for the current iterable.
<V> ListMultimap<V,T>	groupBy(Function<? super T,? extends V> function)
<V> ListMultimap<V,T>	groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
<V> MapIterable<V,T>	groupByUniqueKey(Function<? super T,? extends V> function)
protected boolean	isOrdered()
ParallelListIterable<T>	reject(Predicate<? super T> predicate)	Creates a parallel iterable for rejecting elements from the current iterable.
<P> ParallelListIterable<T>	rejectWith(Predicate2<? super T,? super P> predicate, P parameter)
ParallelListIterable<T>	select(Predicate<? super T> predicate)	Creates a parallel iterable for selecting elements from the current iterable.
<S> ParallelListIterable<S>	selectInstancesOf(java.lang.Class<S> clazz)
<P> ParallelListIterable<T>	selectWith(Predicate2<? super T,? super P> predicate, P parameter)
java.lang.Object[]	toArray()
<E> E[]	toArray(E[] array)

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, getBatchSize, getExecutorService, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, split, 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, allSatisfy, allSatisfyWith, anySatisfy, anySatisfyWith, appendString, appendString, appendString, count, countWith, detect, detectIfNone, detectWith, detectWithIfNone, forEach, 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

Constructor Detail

AbstractParallelListIterable

public AbstractParallelListIterable()

Method Detail

isOrdered

protected boolean isOrdered()

Specified by:

isOrdered in class AbstractParallelIterable<T,B extends ListBatch<T>>

asUnique

public ParallelUnsortedSetIterable<T> asUnique()

Specified by:

asUnique in interface ParallelIterable<T>

Specified by:

asUnique in interface ParallelListIterable<T>

select

public ParallelListIterable<T> select(Predicate<? super T> predicate)

Description copied from interface: ParallelListIterable

Creates a parallel iterable for selecting elements from the current iterable.

Specified by:

select in interface ParallelIterable<T>

Specified by:

select in interface ParallelListIterable<T>

selectWith

public <P> ParallelListIterable<T> selectWith(Predicate2<? super T,? super P> predicate,
                                              P parameter)

Specified by:

selectWith in interface ParallelIterable<T>

Specified by:

selectWith in interface ParallelListIterable<T>

selectInstancesOf

public <S> ParallelListIterable<S> selectInstancesOf(java.lang.Class<S> clazz)

Specified by:

selectInstancesOf in interface ParallelIterable<T>

Specified by:

selectInstancesOf in interface ParallelListIterable<T>

reject

public ParallelListIterable<T> reject(Predicate<? super T> predicate)

Description copied from interface: ParallelListIterable

Creates a parallel iterable for rejecting elements from the current iterable.

Specified by:

reject in interface ParallelIterable<T>

Specified by:

reject in interface ParallelListIterable<T>

rejectWith

public <P> ParallelListIterable<T> rejectWith(Predicate2<? super T,? super P> predicate,
                                              P parameter)

Specified by:

rejectWith in interface ParallelIterable<T>

Specified by:

rejectWith in interface ParallelListIterable<T>

collect

public <V> ParallelListIterable<V> collect(Function<? super T,? extends V> function)

Description copied from interface: ParallelListIterable

Creates a parallel iterable for collecting elements from the current iterable.

Specified by:

collect in interface ParallelIterable<T>

Specified by:

collect in interface ParallelListIterable<T>

collectWith

public <P,V> ParallelListIterable<V> collectWith(Function2<? super T,? super P,? extends V> function,
                                                       P parameter)

Specified by:

collectWith in interface ParallelIterable<T>

Specified by:

collectWith in interface ParallelListIterable<T>

collectIf

public <V> ParallelListIterable<V> collectIf(Predicate<? super T> predicate,
                                             Function<? super T,? extends V> function)

Description copied from interface: ParallelListIterable

Creates a parallel iterable for selecting and collecting elements from the current iterable.

Specified by:

collectIf in interface ParallelIterable<T>

Specified by:

collectIf in interface ParallelListIterable<T>

flatCollect

public <V> ParallelListIterable<V> flatCollect(Function<? super T,? extends java.lang.Iterable<V>> function)

Description copied from interface: ParallelListIterable

Creates a parallel flattening iterable for the current iterable.

Specified by:

flatCollect in interface ParallelIterable<T>

Specified by:

flatCollect in interface ParallelListIterable<T>

groupBy

public <V> ListMultimap<V,T> groupBy(Function<? super T,? extends V> function)

Specified by:

groupBy in interface ParallelIterable<T>

Specified by:

groupBy in interface ParallelListIterable<T>

groupByEach

public <V> ListMultimap<V,T> groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)

Specified by:

groupByEach in interface ParallelIterable<T>

Specified by:

groupByEach in interface ParallelListIterable<T>

groupByUniqueKey

public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)

Specified by:

groupByUniqueKey in interface ParallelIterable<T>

Overrides:

groupByUniqueKey in class AbstractParallelIterable<T,B extends ListBatch<T>>

toArray

public java.lang.Object[] toArray()

Specified by:

toArray in interface ParallelIterable<T>

toArray

public <E> E[] toArray(E[] array)

Specified by:

toArray in interface ParallelIterable<T>

Overrides:

toArray in class AbstractParallelIterable<T,B extends ListBatch<T>>