public class CompletionStageRxInvokerProvider extends Object implements RxInvokerProvider<CompletionStageRxInvoker>
Constructor and Description |
---|
CompletionStageRxInvokerProvider() |
Modifier and Type | Method and 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. |
public boolean isProviderFor(Class<?> clazz)
RxInvokerProvider
RxInvoker
subclass.isProviderFor
in interface RxInvokerProvider<CompletionStageRxInvoker>
clazz
- RxInvoker
subclass.true
when this provider provides given RxInvoker
subclass, false
otherwise.public CompletionStageRxInvoker getRxInvoker(SyncInvoker syncInvoker, ExecutorService executorService)
RxInvokerProvider
RxInvoker
implementation instance.
The returned instance has to be thread safe.
getRxInvoker
in interface RxInvokerProvider<CompletionStageRxInvoker>
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 © 2019 JBoss by Red Hat. All rights reserved.