R
- public final class CacheIntermediatePublisher<R> extends Object implements ModifiedValueFunction<org.reactivestreams.Publisher<Object>,org.reactivestreams.Publisher<R>>, InjectableComponent
Modifier and Type | Class and Description |
---|---|
static class |
CacheIntermediatePublisher.ReducerExternalizer |
Constructor and Description |
---|
CacheIntermediatePublisher(Queue<IntermediateOperation> intOps) |
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.
|
public CacheIntermediatePublisher(Queue<IntermediateOperation> intOps)
public org.reactivestreams.Publisher<R> apply(org.reactivestreams.Publisher<Object> objectPublisher)
public boolean isModified()
ModifiedValueFunction
isModified
in interface ModifiedValueFunction<org.reactivestreams.Publisher<Object>,org.reactivestreams.Publisher<R>>
public void inject(ComponentRegistry registry)
inject
in interface InjectableComponent
Copyright © 2021 JBoss by Red Hat. All rights reserved.