Package io.fluxcapacitor.javaclient.tracking.handling

Class StatefulHandler.StatefulHandlerInvoker

java.lang.Object

io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker

io.fluxcapacitor.javaclient.tracking.handling.StatefulHandler.StatefulHandlerInvoker

All Implemented Interfaces:

HandlerInvoker

Enclosing class:

StatefulHandler

protected class StatefulHandler.StatefulHandlerInvoker
extends HandlerInvoker.DelegatingHandlerInvoker

Nested Class Summary

Nested classes/interfaces inherited from interface io.fluxcapacitor.common.handling.HandlerInvoker

HandlerInvoker.DelegatingHandlerInvoker, HandlerInvoker.SimpleInvoker

Field Summary

Fields inherited from class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker

delegate

Constructor Summary

Constructors

Constructor	Description
StatefulHandlerInvoker(HandlerInvoker delegate, Entry<?> currentEntry, DeserializingMessage message)

Method Summary

Modifier and Type	Method	Description
protected Object	computeId(Object handler)
protected void	handleResult(Object result)
Object	invoke(BiFunction<Object,Object,Object> combiner)	Invokes the handler and combines results using the given combiner function.

Methods inherited from class io.fluxcapacitor.common.handling.HandlerInvoker.DelegatingHandlerInvoker

expectResult, getMethod, getMethodAnnotation, getTargetClass, isPassive, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.fluxcapacitor.common.handling.HandlerInvoker

andFinally, invoke

Constructor Details

StatefulHandlerInvoker

public StatefulHandlerInvoker(HandlerInvoker delegate,
 Entry<?> currentEntry,
 DeserializingMessage message)

Method Details

invoke

public Object invoke(BiFunction<Object,Object,Object> combiner)

Description copied from interface: HandlerInvoker

Invokes the handler and combines results using the given combiner function. Used when aggregating results from multiple invokers (e.g. HandlerInvoker.join(List)).

Parameters:

combiner - function to combine multiple results

Returns:

the combined result

handleResult

protected void handleResult(Object result)

computeId

protected Object computeId(Object handler)