Module jpastreamer.pipeline.standard

Package com.speedment.jpastreamer.pipeline.terminal.standard

Class StandardTerminalOperationFactory

java.lang.Object

com.speedment.jpastreamer.pipeline.terminal.standard.StandardTerminalOperationFactory

All Implemented Interfaces:

BaseStreamTerminalOperationFactory, TerminalOperationFactory

public class StandardTerminalOperationFactory
extends Object
implements TerminalOperationFactory

Constructor Summary

Constructors

Constructor	Description
StandardTerminalOperationFactory()

Method Summary

Modifier and Type	Method	Description
<T> TerminalOperation<Stream<T>,Long>	acquireCount()
<T> TerminalOperation<Stream<T>,Optional<T>>	acquireFindAny()
<T> TerminalOperation<Stream<T>,Optional<T>>	acquireFindFirst()
<T, S extends BaseStream<T, S>> TerminalOperation<S,Iterator<T>>	acquireIterator()
<T, S extends BaseStream<T, S>> TerminalOperation<S,Spliterator<T>>	acquireSpliterator()
<T> TerminalOperation<Stream<T>,Object[]>	acquireToArray()
<T> TerminalOperation<Stream<T>,Boolean>	createAllMatch(Predicate<? super T> predicate)
<T> TerminalOperation<Stream<T>,Boolean>	createAnyMatch(Predicate<? super T> predicate)
<T, R> TerminalOperation<Stream<T>,R>	createCollect(Supplier<R> supplier, BiConsumer<R,? super T> accumulator, BiConsumer<R,R> combiner)
<T, R, A> TerminalOperation<Stream<T>,R>	createCollect(Collector<? super T,A,R> collector)
<T> TerminalOperation<Stream<T>,Void>	createForEach(Consumer<? super T> action)
<T> TerminalOperation<Stream<T>,Void>	createForEachOrdered(Consumer<? super T> action)
<T> TerminalOperation<Stream<T>,Optional<T>>	createMax(Comparator<? super T> comparator)
<T> TerminalOperation<Stream<T>,Optional<T>>	createMin(Comparator<? super T> comparator)
<T> TerminalOperation<Stream<T>,Boolean>	createNoneMatch(Predicate<? super T> predicate)
<T> TerminalOperation<Stream<T>,Optional<T>>	createReduce(BinaryOperator<T> accumulator)
<T> TerminalOperation<Stream<T>,T>	createReduce(T identity, BinaryOperator<T> accumulator)
<T, U> TerminalOperation<Stream<T>,U>	createReduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)
<T, A> TerminalOperation<Stream<T>,A[]>	createToArray(IntFunction<A[]> generator)

Methods inherited from class java.lang.Object

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

Constructor Details

StandardTerminalOperationFactory

public StandardTerminalOperationFactory()

Method Details

createForEach

public <T> TerminalOperation<Stream<T>,Void> createForEach(Consumer<? super T> action)

Specified by:

createForEach in interface TerminalOperationFactory

createForEachOrdered

public <T> TerminalOperation<Stream<T>,Void> createForEachOrdered(Consumer<? super T> action)

Specified by:

createForEachOrdered in interface TerminalOperationFactory

acquireToArray

public <T> TerminalOperation<Stream<T>,Object[]> acquireToArray()

Specified by:

acquireToArray in interface TerminalOperationFactory

createToArray

public <T,
A> TerminalOperation<Stream<T>,A[]> createToArray(IntFunction<A[]> generator)

Specified by:

createToArray in interface TerminalOperationFactory

createReduce

public <T> TerminalOperation<Stream<T>,T> createReduce(T identity,
 BinaryOperator<T> accumulator)

Specified by:

createReduce in interface TerminalOperationFactory

createReduce

public <T> TerminalOperation<Stream<T>,Optional<T>> createReduce(BinaryOperator<T> accumulator)

Specified by:

createReduce in interface TerminalOperationFactory

createReduce

public <T,
U> TerminalOperation<Stream<T>,U> createReduce(U identity,
 BiFunction<U,? super T,U> accumulator,
 BinaryOperator<U> combiner)

Specified by:

createReduce in interface TerminalOperationFactory

createCollect

public <T,
R> TerminalOperation<Stream<T>,R> createCollect(Supplier<R> supplier,
 BiConsumer<R,? super T> accumulator,
 BiConsumer<R,R> combiner)

Specified by:

createCollect in interface TerminalOperationFactory

createCollect

public <T,
R,
A> TerminalOperation<Stream<T>,R> createCollect(Collector<? super T,A,R> collector)

Specified by:

createCollect in interface TerminalOperationFactory

createMin

public <T> TerminalOperation<Stream<T>,Optional<T>> createMin(Comparator<? super T> comparator)

Specified by:

createMin in interface TerminalOperationFactory

createMax

public <T> TerminalOperation<Stream<T>,Optional<T>> createMax(Comparator<? super T> comparator)

Specified by:

createMax in interface TerminalOperationFactory

acquireCount

public <T> TerminalOperation<Stream<T>,Long> acquireCount()

Specified by:

acquireCount in interface TerminalOperationFactory

createAnyMatch

public <T> TerminalOperation<Stream<T>,Boolean> createAnyMatch(Predicate<? super T> predicate)

Specified by:

createAnyMatch in interface TerminalOperationFactory

createAllMatch

public <T> TerminalOperation<Stream<T>,Boolean> createAllMatch(Predicate<? super T> predicate)

Specified by:

createAllMatch in interface TerminalOperationFactory

createNoneMatch

public <T> TerminalOperation<Stream<T>,Boolean> createNoneMatch(Predicate<? super T> predicate)

Specified by:

createNoneMatch in interface TerminalOperationFactory

acquireFindFirst

public <T> TerminalOperation<Stream<T>,Optional<T>> acquireFindFirst()

Specified by:

acquireFindFirst in interface TerminalOperationFactory

acquireFindAny

public <T> TerminalOperation<Stream<T>,Optional<T>> acquireFindAny()

Specified by:

acquireFindAny in interface TerminalOperationFactory

acquireIterator

public <T,
S extends BaseStream<T,
S>>
TerminalOperation<S,Iterator<T>> acquireIterator()

Specified by:

acquireIterator in interface BaseStreamTerminalOperationFactory

acquireSpliterator

public <T,
S extends BaseStream<T,
S>>
TerminalOperation<S,Spliterator<T>> acquireSpliterator()

Specified by:

acquireSpliterator in interface BaseStreamTerminalOperationFactory