T - RxInvoker subclass type.public interface RxInvokerProvider<T extends RxInvoker>
RxInvoker provider.
RxInvokerProvider must be registered in the client runtime using Configurable.register(Class).
It provides a way to plug-in support for other reactive implementations,
see Invocation.Builder.rx(Class).
| Modifier and Type | Method and Description |
|---|---|
T |
getRxInvoker(SyncInvoker syncInvoker,
java.util.concurrent.ExecutorService executorService)
Get
RxInvoker implementation instance. |
boolean |
isProviderFor(java.lang.Class<?> clazz)
Determine if this is a provider for the given
RxInvoker subclass. |
boolean isProviderFor(java.lang.Class<?> clazz)
RxInvoker subclass.clazz - RxInvoker subclass.true when this provider provides given RxInvoker subclass, false otherwise.T getRxInvoker(SyncInvoker syncInvoker, java.util.concurrent.ExecutorService executorService)
RxInvoker implementation instance.
The returned instance has to be thread safe.
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.RxInvoker subclass.ClientBuilder.executorService(ExecutorService)