Package dev.getelements.elements.rt.routing

Class AggregateConsumer<T>

java.lang.Object

dev.getelements.elements.rt.routing.AggregateConsumer<T>

Type Parameters:

T -

All Implemented Interfaces:

Consumer<T>

public class AggregateConsumer<T>
extends Object
implements Consumer<T>

Given the expected number of calls, this generates a Consumer which will aggregate all results together until a set number of responses occur. Once the last invocation occurs, this instance will invoke the delegate Consumer instance to finis the call.

Constructor Summary

Constructors

Constructor	Description
AggregateConsumer(Consumer<T> delegate, int expected, Supplier<T> initalSupplier, BinaryOperator<T> aggregator)

Method Summary

Modifier and Type	Method	Description
void	accept(T t)

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.Consumer

andThen

Constructor Details

AggregateConsumer

public AggregateConsumer(Consumer<T> delegate,
 int expected,
 Supplier<T> initalSupplier,
 BinaryOperator<T> aggregator)

Method Details

accept

public void accept(T t)

Specified by:

accept in interface Consumer<T>