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 java.lang.Object implements javax.ws.rs.client.RxInvoker<T>
Default implementation ofreactive invoker
. Extensions of this class are supposed to implementRxInvoker.method(String, Entity, Class)
andRxInvoker.method(String, Entity, GenericType)
methods to which implementations of the rest of the methods from the contract delegate to.- Since:
- 2.26
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.ExecutorService
executorService
private javax.ws.rs.client.SyncInvoker
syncInvoker
-
Constructor Summary
Constructors Constructor Description AbstractRxInvoker(javax.ws.rs.client.SyncInvoker syncInvoker, java.util.concurrent.ExecutorService executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description T
delete()
<R> T
delete(java.lang.Class<R> responseType)
<R> T
delete(javax.ws.rs.core.GenericType<R> responseType)
T
get()
<R> T
get(java.lang.Class<R> responseType)
<R> T
get(javax.ws.rs.core.GenericType<R> responseType)
protected java.util.concurrent.ExecutorService
getExecutorService()
Return executorService service this reactive invoker was initialized with.protected javax.ws.rs.client.SyncInvoker
getSyncInvoker()
Return invocation builder this reactive invoker was initialized with.T
head()
T
method(java.lang.String name)
<R> T
method(java.lang.String name, java.lang.Class<R> responseType)
T
method(java.lang.String name, javax.ws.rs.client.Entity<?> entity)
<R> T
method(java.lang.String name, javax.ws.rs.core.GenericType<R> responseType)
T
options()
<R> T
options(java.lang.Class<R> responseType)
<R> T
options(javax.ws.rs.core.GenericType<R> responseType)
T
post(javax.ws.rs.client.Entity<?> entity)
<R> T
post(javax.ws.rs.client.Entity<?> entity, java.lang.Class<R> clazz)
<R> T
post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
T
put(javax.ws.rs.client.Entity<?> entity)
<R> T
put(javax.ws.rs.client.Entity<?> entity, java.lang.Class<R> clazz)
<R> T
put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
T
trace()
<R> T
trace(java.lang.Class<R> responseType)
<R> T
trace(javax.ws.rs.core.GenericType<R> responseType)
-
-
-
Method Detail
-
getSyncInvoker
protected javax.ws.rs.client.SyncInvoker getSyncInvoker()
Return invocation builder this reactive invoker was initialized with.- Returns:
- non-null invocation builder.
-
getExecutorService
protected java.util.concurrent.ExecutorService getExecutorService()
Return executorService service this reactive invoker was initialized with.- Returns:
- executorService service instance or
null
.
-
get
public <R> T get(java.lang.Class<R> responseType)
- Specified by:
get
in interfacejavax.ws.rs.client.RxInvoker<T>
-
get
public <R> T get(javax.ws.rs.core.GenericType<R> responseType)
- Specified by:
get
in interfacejavax.ws.rs.client.RxInvoker<T>
-
put
public T put(javax.ws.rs.client.Entity<?> entity)
- Specified by:
put
in interfacejavax.ws.rs.client.RxInvoker<T>
-
put
public <R> T put(javax.ws.rs.client.Entity<?> entity, java.lang.Class<R> clazz)
- Specified by:
put
in interfacejavax.ws.rs.client.RxInvoker<T>
-
put
public <R> T put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
- Specified by:
put
in interfacejavax.ws.rs.client.RxInvoker<T>
-
post
public T post(javax.ws.rs.client.Entity<?> entity)
- Specified by:
post
in interfacejavax.ws.rs.client.RxInvoker<T>
-
post
public <R> T post(javax.ws.rs.client.Entity<?> entity, java.lang.Class<R> clazz)
- Specified by:
post
in interfacejavax.ws.rs.client.RxInvoker<T>
-
post
public <R> T post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
- Specified by:
post
in interfacejavax.ws.rs.client.RxInvoker<T>
-
delete
public <R> T delete(java.lang.Class<R> responseType)
- Specified by:
delete
in interfacejavax.ws.rs.client.RxInvoker<T>
-
delete
public <R> T delete(javax.ws.rs.core.GenericType<R> responseType)
- Specified by:
delete
in interfacejavax.ws.rs.client.RxInvoker<T>
-
options
public <R> T options(java.lang.Class<R> responseType)
- Specified by:
options
in interfacejavax.ws.rs.client.RxInvoker<T>
-
options
public <R> T options(javax.ws.rs.core.GenericType<R> responseType)
- Specified by:
options
in interfacejavax.ws.rs.client.RxInvoker<T>
-
trace
public <R> T trace(java.lang.Class<R> responseType)
- Specified by:
trace
in interfacejavax.ws.rs.client.RxInvoker<T>
-
trace
public <R> T trace(javax.ws.rs.core.GenericType<R> responseType)
- Specified by:
trace
in interfacejavax.ws.rs.client.RxInvoker<T>
-
method
public T method(java.lang.String name)
- Specified by:
method
in interfacejavax.ws.rs.client.RxInvoker<T>
-
method
public <R> T method(java.lang.String name, java.lang.Class<R> responseType)
- Specified by:
method
in interfacejavax.ws.rs.client.RxInvoker<T>
-
method
public <R> T method(java.lang.String name, javax.ws.rs.core.GenericType<R> responseType)
- Specified by:
method
in interfacejavax.ws.rs.client.RxInvoker<T>
-
-