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.