org.infinispan.stream.impl.termop.object

Class ForEachOperation<K,V>

java.lang.Object

org.infinispan.stream.impl.termop.BaseTerminalOperation

org.infinispan.stream.impl.termop.AbstractForEachOperation<K,V,Stream<V>>

org.infinispan.stream.impl.termop.object.ForEachOperation<K,V>

Type Parameters:

K - key type of the supplied stream

V - resulting value type

All Implemented Interfaces:

KeyTrackingTerminalOperation<K,V,K>, SegmentAwareOperation

public class ForEachOperation<K,V>
extends AbstractForEachOperation<K,V,Stream<V>>

Terminal operation that handles for each where no map operations are defined

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.stream.impl.KeyTrackingTerminalOperation

KeyTrackingTerminalOperation.IntermediateCollector<C>

Field Summary

Fields inherited from class org.infinispan.stream.impl.termop.BaseTerminalOperation

intermediateOperations, supplier

Constructor Summary

Constructors

Constructor and Description
ForEachOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<CacheEntry>> supplier, int batchSize, Consumer<? super V> consumer)

Method Summary

Modifier and Type	Method and Description
Consumer<? super V>	getConsumer()
void	handleInjection(ComponentRegistry registry) Handles injection of components for various intermediate and this operation.
protected void	handleList(List<V> list)
protected void	handleStreamForEach(Stream<V> stream, List<V> list)

Methods inherited from class org.infinispan.stream.impl.termop.AbstractForEachOperation

getBatchSize, lostSegment, performOperation, performOperationRehashAware

Methods inherited from class org.infinispan.stream.impl.termop.BaseTerminalOperation

getIntermediateOperations, setSupplier

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.stream.impl.KeyTrackingTerminalOperation

setSupplier

Constructor Detail

ForEachOperation

public ForEachOperation(Iterable<IntermediateOperation> intermediateOperations,
                        Supplier<Stream<CacheEntry>> supplier,
                        int batchSize,
                        Consumer<? super V> consumer)

Method Detail

handleList

protected void handleList(List<V> list)

Specified by:

handleList in class AbstractForEachOperation<K,V,Stream<V>>

handleStreamForEach

protected void handleStreamForEach(Stream<V> stream,
                                   List<V> list)

Specified by:

handleStreamForEach in class AbstractForEachOperation<K,V,Stream<V>>

getConsumer

public Consumer<? super V> getConsumer()

handleInjection

public void handleInjection(ComponentRegistry registry)

Description copied from interface: KeyTrackingTerminalOperation

Handles injection of components for various intermediate and this operation.

Specified by:

handleInjection in interface KeyTrackingTerminalOperation<K,V,K>

Overrides:

handleInjection in class BaseTerminalOperation

Parameters:

registry - component registry to use