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,
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 © 2018,2020 Eclipse Foundation.
Use is subject to license terms.