Package org.infinispan.stream.impl
Class CacheIntermediatePublisher<R>
- java.lang.Object
-
- org.infinispan.stream.impl.CacheIntermediatePublisher<R>
-
- Type Parameters:
R
-
- All Implemented Interfaces:
Function<org.reactivestreams.Publisher<Object>,org.reactivestreams.Publisher<R>>
,org.infinispan.commands.functional.functions.InjectableComponent
,ModifiedValueFunction<org.reactivestreams.Publisher<Object>,org.reactivestreams.Publisher<R>>
public final class CacheIntermediatePublisher<R> extends Object implements ModifiedValueFunction<org.reactivestreams.Publisher<Object>,org.reactivestreams.Publisher<R>>, org.infinispan.commands.functional.functions.InjectableComponent
Function that is used to encapsulate multiple intermediate operations and perform them lazily when the function is applied.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CacheIntermediatePublisher.ReducerExternalizer
-
Constructor Summary
Constructors Constructor Description CacheIntermediatePublisher(Iterable<org.infinispan.stream.impl.intops.IntermediateOperation<?,?,?,?>> intOps)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.reactivestreams.Publisher<R>
apply(org.reactivestreams.Publisher<Object> objectPublisher)
void
inject(ComponentRegistry registry)
boolean
isModified()
This method should return true when this function changes the actual values of the Publisher.
-
-
-
Constructor Detail
-
CacheIntermediatePublisher
public CacheIntermediatePublisher(Iterable<org.infinispan.stream.impl.intops.IntermediateOperation<?,?,?,?>> intOps)
-
-
Method Detail
-
apply
public org.reactivestreams.Publisher<R> apply(org.reactivestreams.Publisher<Object> objectPublisher)
-
isModified
public boolean isModified()
Description copied from interface:ModifiedValueFunction
This method should return true when this function changes the actual values of the Publisher. This can be useful for some optimizations that may need to track produced values from the original.- Specified by:
isModified
in interfaceModifiedValueFunction<org.reactivestreams.Publisher<Object>,org.reactivestreams.Publisher<R>>
- Returns:
- if the values in the publisher are changed
-
inject
public void inject(ComponentRegistry registry)
- Specified by:
inject
in interfaceorg.infinispan.commands.functional.functions.InjectableComponent
-
-