Package org.jboss.resteasy.client.jaxrs.internal

Class CompletionStageRxInvokerProvider

java.lang.Object

org.jboss.resteasy.client.jaxrs.internal.CompletionStageRxInvokerProvider

All Implemented Interfaces:

RxInvokerProvider<CompletionStageRxInvoker>

public class CompletionStageRxInvokerProvider
extends Object
implements RxInvokerProvider<CompletionStageRxInvoker>

Constructor Summary

Constructors

Constructor	Description
CompletionStageRxInvokerProvider()

Method Summary

Modifier and Type	Method	Description
CompletionStageRxInvoker	getRxInvoker(SyncInvoker syncInvoker, ExecutorService executorService)	Get RxInvoker implementation instance.
boolean	isProviderFor(Class<?> clazz)	Determine if this is a provider for the given RxInvoker subclass.

Methods inherited from class java.lang.Object

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

Constructor Detail

CompletionStageRxInvokerProvider

public CompletionStageRxInvokerProvider()

Method Detail

isProviderFor

public boolean isProviderFor(Class<?> clazz)

Description copied from interface: RxInvokerProvider

Determine if this is a provider for the given RxInvoker subclass.

Specified by:

isProviderFor in interface RxInvokerProvider<CompletionStageRxInvoker>

Parameters:

clazz - RxInvoker subclass.

Returns:

true when this provider provides given RxInvoker subclass, false otherwise.

getRxInvoker

public CompletionStageRxInvoker getRxInvoker(SyncInvoker syncInvoker,
                                             ExecutorService executorService)

Description copied from interface: RxInvokerProvider

Get RxInvoker implementation instance.

The returned instance has to be thread safe.

Specified by:

getRxInvoker in interface RxInvokerProvider<CompletionStageRxInvoker>

Parameters:

syncInvoker - SyncInvoker used to execute current request.

executorService - executor service, which should be used for executing reactive callbacks invocations. It can be null; in that case it's up to the implementation to choose the best ExecutorService in given environment.

Returns:

instance of the RxInvoker subclass.

See Also:

ClientBuilder.executorService(ExecutorService)