Package org.glassfish.jersey.client
Class AbstractRxInvoker<T>
java.lang.Object
org.glassfish.jersey.client.AbstractRxInvoker<T>
- Type Parameters:
T
- the asynchronous/event-based completion aware type. The given type should be parametrized with the actual response type.
- All Implemented Interfaces:
javax.ws.rs.client.RxInvoker<T>
- Direct Known Subclasses:
JerseyCompletionStageRxInvoker
public abstract class AbstractRxInvoker<T>
extends Object
implements javax.ws.rs.client.RxInvoker<T>
Default implementation of
reactive invoker
. Extensions of this class are
supposed to implement RxInvoker.method(String, Entity, Class)
and
RxInvoker.method(String, Entity, GenericType)
methods to which implementations of the rest
of the methods from the contract delegate to.- Since:
- 2.26
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ExecutorService
private final javax.ws.rs.client.SyncInvoker
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractRxInvoker
(javax.ws.rs.client.SyncInvoker syncInvoker, ExecutorService executor) -
Method Summary
Modifier and TypeMethodDescriptiondelete()
<R> T
<R> T
delete
(javax.ws.rs.core.GenericType<R> responseType) get()
<R> T
<R> T
get
(javax.ws.rs.core.GenericType<R> responseType) protected ExecutorService
Return executorService service this reactive invoker was initialized with.protected javax.ws.rs.client.SyncInvoker
Return invocation builder this reactive invoker was initialized with.head()
<R> T
<R> T
options()
<R> T
<R> T
options
(javax.ws.rs.core.GenericType<R> responseType) post
(javax.ws.rs.client.Entity<?> entity) <R> T
<R> T
post
(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type) put
(javax.ws.rs.client.Entity<?> entity) <R> T
<R> T
put
(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type) trace()
<R> T
<R> T
trace
(javax.ws.rs.core.GenericType<R> responseType) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface javax.ws.rs.client.RxInvoker
method, method
-
Field Details
-
syncInvoker
private final javax.ws.rs.client.SyncInvoker syncInvoker -
executorService
-
-
Constructor Details
-
AbstractRxInvoker
-
-
Method Details
-
getSyncInvoker
protected javax.ws.rs.client.SyncInvoker getSyncInvoker()Return invocation builder this reactive invoker was initialized with.- Returns:
- non-null invocation builder.
-
getExecutorService
Return executorService service this reactive invoker was initialized with.- Returns:
- executorService service instance or
null
.
-
get
- Specified by:
get
in interfacejavax.ws.rs.client.RxInvoker<T>
-
get
- Specified by:
get
in interfacejavax.ws.rs.client.RxInvoker<T>
-
get
- Specified by:
get
in interfacejavax.ws.rs.client.RxInvoker<T>
-
put
- Specified by:
put
in interfacejavax.ws.rs.client.RxInvoker<T>
-
put
- Specified by:
put
in interfacejavax.ws.rs.client.RxInvoker<T>
-
put
- Specified by:
put
in interfacejavax.ws.rs.client.RxInvoker<T>
-
post
- Specified by:
post
in interfacejavax.ws.rs.client.RxInvoker<T>
-
post
- Specified by:
post
in interfacejavax.ws.rs.client.RxInvoker<T>
-
post
- Specified by:
post
in interfacejavax.ws.rs.client.RxInvoker<T>
-
delete
- Specified by:
delete
in interfacejavax.ws.rs.client.RxInvoker<T>
-
delete
- Specified by:
delete
in interfacejavax.ws.rs.client.RxInvoker<T>
-
delete
- Specified by:
delete
in interfacejavax.ws.rs.client.RxInvoker<T>
-
head
- Specified by:
head
in interfacejavax.ws.rs.client.RxInvoker<T>
-
options
- Specified by:
options
in interfacejavax.ws.rs.client.RxInvoker<T>
-
options
- Specified by:
options
in interfacejavax.ws.rs.client.RxInvoker<T>
-
options
- Specified by:
options
in interfacejavax.ws.rs.client.RxInvoker<T>
-
trace
- Specified by:
trace
in interfacejavax.ws.rs.client.RxInvoker<T>
-
trace
- Specified by:
trace
in interfacejavax.ws.rs.client.RxInvoker<T>
-
trace
- Specified by:
trace
in interfacejavax.ws.rs.client.RxInvoker<T>
-
method
- Specified by:
method
in interfacejavax.ws.rs.client.RxInvoker<T>
-
method
- Specified by:
method
in interfacejavax.ws.rs.client.RxInvoker<T>
-
method
- Specified by:
method
in interfacejavax.ws.rs.client.RxInvoker<T>
-
method
- Specified by:
method
in interfacejavax.ws.rs.client.RxInvoker<T>
-