Class CacheStreamIntermediateReducer<R>

java.lang.Object

org.infinispan.stream.impl.CacheStreamIntermediateReducer<R>

Type Parameters:

R -

All Implemented Interfaces:

Function<org.reactivestreams.Publisher<Object>, CompletionStage<R>>, InjectableComponent

@ProtoTypeId(1048)
public final class CacheStreamIntermediateReducer<R>
extends Object
implements Function<org.reactivestreams.Publisher<Object>, CompletionStage<R>>, InjectableComponent

Reducer implementation for Distributed Publisher that converts between CacheStream operations to an appropriate Reducer

Method Summary

Modifier and Type	Method	Description
CompletionStage<R>	apply(org.reactivestreams.Publisher<Object> objectPublisher)
void	inject(ComponentRegistry registry)

Methods inherited from class Object

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

Methods inherited from interface Function

andThen, compose

Method Details

apply

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

Specified by:

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

inject

public void inject(ComponentRegistry registry)

Specified by:

inject in interface InjectableComponent