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 | Description |
|---|---|---|
T |
getRxInvoker(SyncInvoker syncInvoker,
ExecutorService executorService) |
Get
RxInvoker implementation instance. |
boolean |
isProviderFor(Class<?> clazz) |
Determine if this is a provider for the given
RxInvoker subclass. |
boolean isProviderFor(Class<?> clazz)
RxInvoker subclass.clazz - RxInvoker subclass.true when this provider provides given RxInvoker subclass, false otherwise.T getRxInvoker(SyncInvoker syncInvoker, 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)Copyright (c) 2019 Eclipse Foundation. Licensed under Eclipse Foundation Specification License.