org.infinispan.stream.impl.termop

Class BaseTerminalOperation

java.lang.Object

org.infinispan.stream.impl.termop.BaseTerminalOperation

Direct Known Subclasses:

AbstractForEachOperation, FlatMapIteratorOperation, ForEachDoubleOperation, ForEachIntOperation, ForEachLongOperation, MapIteratorOperation, SegmentRetryingOperation, SingleRunOperation

public abstract class BaseTerminalOperation
extends Object

Abstract instance that provides common code needed for all terminal operations. Note this class doesn't extend any interface due to the fact that different terminal operations have possibly different interfaces to implement however all of them require the information stored here.

Field Summary

Fields

Modifier and Type	Field and Description
protected Iterable<IntermediateOperation>	intermediateOperations
protected Supplier<? extends BaseStream<?,?>>	supplier

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseTerminalOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<? extends BaseStream<?,?>> supplier)

Method Summary

Modifier and Type	Method and Description
Iterable<IntermediateOperation>	getIntermediateOperations()
void	handleInjection(ComponentRegistry registry)
void	setSupplier(Supplier<? extends Stream<?>> supplier)

Methods inherited from class java.lang.Object

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

Field Detail

intermediateOperations

protected final Iterable<IntermediateOperation> intermediateOperations

supplier

protected transient Supplier<? extends BaseStream<?,?>> supplier

Constructor Detail

BaseTerminalOperation

protected BaseTerminalOperation(Iterable<IntermediateOperation> intermediateOperations,
                                Supplier<? extends BaseStream<?,?>> supplier)

Method Detail

getIntermediateOperations

public Iterable<IntermediateOperation> getIntermediateOperations()

setSupplier

public void setSupplier(Supplier<? extends Stream<?>> supplier)

handleInjection

public void handleInjection(ComponentRegistry registry)