Package dev.getelements.elements.rt.jrpc

Class SingleAsyncResultHandlerStrategy

java.lang.Object

dev.getelements.elements.rt.jrpc.SingleAsyncResultHandlerStrategy

All Implemented Interfaces:

ResultHandlerStrategy

public class SingleAsyncResultHandlerStrategy
extends Object
implements ResultHandlerStrategy

Represents a single async style RPC method. This supports a single return type, either asynchronous or synchronous. This is useful for JSON-RPC where the response document tends to be a single object, rather than a series of responses sent during the invocation process.

Constructor Summary

Constructors

Constructor	Description
SingleAsyncResultHandlerStrategy()

Method Summary

Modifier and Type	Method	Description
Consumer<InvocationError>	getAsyncInvocationErrorConsumer()	Gets the async invocation error consumers.
List<Consumer<InvocationResult>>	getAsyncInvocationResultConsumers()	Returns the async invocation result consumers.
Consumer<InvocationError>	getSyncErrorConsumer()	Returns the sync error consumer.
Consumer<InvocationResult>	getSyncResultConsumer()	Returns the sync result consumer.
Subscription	onError(Consumer<Throwable> finalResult)	Handles the final error result.
Subscription	onFinalResult(Consumer<Object> finalResult)	Handles the final result.

Methods inherited from class java.lang.Object

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

Constructor Details

SingleAsyncResultHandlerStrategy

public SingleAsyncResultHandlerStrategy()

Method Details

getSyncResultConsumer

public Consumer<InvocationResult> getSyncResultConsumer()

Description copied from interface: ResultHandlerStrategy

Returns the sync result consumer.

Specified by:

getSyncResultConsumer in interface ResultHandlerStrategy

Returns:

the invocation result consumer.

getSyncErrorConsumer

public Consumer<InvocationError> getSyncErrorConsumer()

Description copied from interface: ResultHandlerStrategy

Returns the sync error consumer.

Specified by:

getSyncErrorConsumer in interface ResultHandlerStrategy

Returns:

the sync error consumer.

getAsyncInvocationResultConsumers

public List<Consumer<InvocationResult>> getAsyncInvocationResultConsumers()

Description copied from interface: ResultHandlerStrategy

Returns the async invocation result consumers.

Specified by:

getAsyncInvocationResultConsumers in interface ResultHandlerStrategy

Returns:

the result consumers.

getAsyncInvocationErrorConsumer

public Consumer<InvocationError> getAsyncInvocationErrorConsumer()

Description copied from interface: ResultHandlerStrategy

Gets the async invocation error consumers.

Specified by:

getAsyncInvocationErrorConsumer in interface ResultHandlerStrategy

Returns:

the async error invocation consumers.

onError

public Subscription onError(Consumer<Throwable> finalResult)

Description copied from interface: ResultHandlerStrategy

Handles the final error result.

Specified by:

onError in interface ResultHandlerStrategy

Returns:

a Subscription

onFinalResult

public Subscription onFinalResult(Consumer<Object> finalResult)

Description copied from interface: ResultHandlerStrategy

Handles the final result.

Specified by:

onFinalResult in interface ResultHandlerStrategy

Returns:

a Subscription