Class ForEachBiOperation<Original,K,V>
- java.lang.Object
-
- org.infinispan.stream.impl.termop.BaseTerminalOperation<Original>
-
- org.infinispan.stream.impl.termop.AbstractForEachOperation<Original,K,V,Stream<V>>
-
- org.infinispan.stream.impl.termop.object.ForEachBiOperation<Original,K,V>
-
- Type Parameters:
Original
- original stream typeK
- key type of the supplied streamV
- resulting value type
- All Implemented Interfaces:
KeyTrackingTerminalOperation<Original,K,V>
,SegmentAwareOperation
public class ForEachBiOperation<Original,K,V> extends AbstractForEachOperation<Original,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 Description ForEachBiOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, BiConsumer<Cache<K,?>,? super V> consumer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BiConsumer<Cache<K,?>,? 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, getToKeyFunction, lostSegment, performForEachOperation, performOperation
-
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
-
-
-
-
Method Detail
-
handleList
protected void handleList(List<V> list)
- Specified by:
handleList
in classAbstractForEachOperation<Original,K,V,Stream<V>>
-
handleStreamForEach
protected void handleStreamForEach(Stream<V> stream, List<V> list)
- Specified by:
handleStreamForEach
in classAbstractForEachOperation<Original,K,V,Stream<V>>
-
getConsumer
public BiConsumer<Cache<K,?>,? 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 interfaceKeyTrackingTerminalOperation<Original,K,V>
- Overrides:
handleInjection
in classBaseTerminalOperation<Original>
- Parameters:
registry
- component registry to use
-
-