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>>, 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>>, 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 and Description
static class	CacheIntermediatePublisher.ReducerExternalizer

Constructor Summary

Constructors

Constructor and Description
CacheIntermediatePublisher(Queue<IntermediateOperation> intOps)

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

CacheIntermediatePublisher

public CacheIntermediatePublisher(Queue<IntermediateOperation> intOps)

Method Detail

apply

public org.reactivestreams.Publisher<R> apply(org.reactivestreams.Publisher<Object> objectPublisher)

Specified by:

apply in interface Function<org.reactivestreams.Publisher<Object>,org.reactivestreams.Publisher<R>>

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 interface ModifiedValueFunction<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 interface InjectableComponent