T
- the asynchronous/event-based completion aware type. The given type should be parametrized with the actual
response type.public abstract class AbstractRxInvoker<T>
extends java.lang.Object
implements javax.ws.rs.client.RxInvoker<T>
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.Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ExecutorService |
executorService |
private javax.ws.rs.client.SyncInvoker |
syncInvoker |
Constructor and Description |
---|
AbstractRxInvoker(javax.ws.rs.client.SyncInvoker syncInvoker,
java.util.concurrent.ExecutorService executor) |
Modifier and Type | Method and 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) |
private final javax.ws.rs.client.SyncInvoker syncInvoker
private final java.util.concurrent.ExecutorService executorService
public AbstractRxInvoker(javax.ws.rs.client.SyncInvoker syncInvoker, java.util.concurrent.ExecutorService executor)
protected javax.ws.rs.client.SyncInvoker getSyncInvoker()
protected java.util.concurrent.ExecutorService getExecutorService()
null
.public <R> T get(java.lang.Class<R> responseType)
get
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T get(javax.ws.rs.core.GenericType<R> responseType)
get
in interface javax.ws.rs.client.RxInvoker<T>
public T put(javax.ws.rs.client.Entity<?> entity)
put
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T put(javax.ws.rs.client.Entity<?> entity, java.lang.Class<R> clazz)
put
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
put
in interface javax.ws.rs.client.RxInvoker<T>
public T post(javax.ws.rs.client.Entity<?> entity)
post
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T post(javax.ws.rs.client.Entity<?> entity, java.lang.Class<R> clazz)
post
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> type)
post
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T delete(java.lang.Class<R> responseType)
delete
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T delete(javax.ws.rs.core.GenericType<R> responseType)
delete
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T options(java.lang.Class<R> responseType)
options
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T options(javax.ws.rs.core.GenericType<R> responseType)
options
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T trace(java.lang.Class<R> responseType)
trace
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T trace(javax.ws.rs.core.GenericType<R> responseType)
trace
in interface javax.ws.rs.client.RxInvoker<T>
public T method(java.lang.String name)
method
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T method(java.lang.String name, java.lang.Class<R> responseType)
method
in interface javax.ws.rs.client.RxInvoker<T>
public <R> T method(java.lang.String name, javax.ws.rs.core.GenericType<R> responseType)
method
in interface javax.ws.rs.client.RxInvoker<T>