org.infinispan.stream.impl

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CacheStreamIntermediateReducer.ReducerExternalizer

Method Summary

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

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

Method Detail

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