Package dev.getelements.elements.rt.remote

Interface LocalInvocationProcessor

public interface LocalInvocationProcessor

Implements the strategy by which the Invocation is dispatched to the local Object in memory.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	LocalInvocationProcessor.ReturnValueStrategy	If the Method called from the Invocation returns a Future instance, this may defined a strategy for handling the result.

Method Summary

Modifier and Type	Method	Description
static LocalInvocationProcessor.ReturnValueStrategy	blockingFutureStrategy()	Returns an instance of LocalInvocationProcessor.ReturnValueStrategy which simply blocks until the Future either returns or throws an instance of Throwable.
static LocalInvocationProcessor.ReturnValueStrategy	ignoreReturnValueStrategy()	Constructs a LocalInvocationProcessor.ReturnValueStrategy which ignores the return value and immediately returns an InvocationResult with a null result.
void	processInvocation(Object target, Invocation invocation, Consumer<InvocationResult> syncInvocationResultConsumer, Consumer<InvocationError> syncInvocationErrorConsumer, List<Consumer<InvocationResult>> asyncInvocationResultConsumerList, Consumer<InvocationError> asyncInvocationErrorConsumer)	Performs the dispatch to the supplied object.
static LocalInvocationProcessor.ReturnValueStrategy	simpleReturnValueStrategy()	Constructs a LocalInvocationProcessor.ReturnValueStrategy which simply hands the result of the Invocation directly to a new instance of InvocationResult and passes it into to the supplied Consumer

Method Details

processInvocation

void processInvocation(Object target,
 Invocation invocation,
 Consumer<InvocationResult> syncInvocationResultConsumer,
 Consumer<InvocationError> syncInvocationErrorConsumer,
 List<Consumer<InvocationResult>> asyncInvocationResultConsumerList,
 Consumer<InvocationError> asyncInvocationErrorConsumer)

Performs the dispatch to the supplied object. Catching and collecting any errors appropriately, and forwarding the result to the supplied Consumer. This should not throw an exception, ever.

Parameters:

target -

invocation -

asyncInvocationResultConsumerList -

asyncInvocationErrorConsumer -

ignoreReturnValueStrategy

static LocalInvocationProcessor.ReturnValueStrategy ignoreReturnValueStrategy()

Constructs a LocalInvocationProcessor.ReturnValueStrategy which ignores the return value and immediately returns an InvocationResult with a null result.

Returns:

the LocalInvocationProcessor.ReturnValueStrategy which passes the result through.

simpleReturnValueStrategy

static LocalInvocationProcessor.ReturnValueStrategy simpleReturnValueStrategy()

Constructs a LocalInvocationProcessor.ReturnValueStrategy which simply hands the result of the Invocation directly to a new instance of InvocationResult and passes it into to the supplied Consumer

Returns:

the LocalInvocationProcessor.ReturnValueStrategy which passes the result through.

blockingFutureStrategy

static LocalInvocationProcessor.ReturnValueStrategy blockingFutureStrategy()

Returns an instance of LocalInvocationProcessor.ReturnValueStrategy which simply blocks until the Future either returns or throws an instance of Throwable.

Returns:

the LocalInvocationProcessor.ReturnValueStrategy which blocks until the future finishes