Package org.jboss.resteasy.reactor
Class MonoRxInvokerImpl
- java.lang.Object
-
- org.jboss.resteasy.client.jaxrs.internal.PublisherRxInvokerImpl
-
- org.jboss.resteasy.reactor.MonoRxInvokerImpl
-
- All Implemented Interfaces:
javax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>,PublisherRxInvoker,MonoRxInvoker
public class MonoRxInvokerImpl extends PublisherRxInvokerImpl implements MonoRxInvoker
-
-
Constructor Summary
Constructors Constructor Description MonoRxInvokerImpl(ClientInvocationBuilder builder)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description reactor.core.publisher.Mono<javax.ws.rs.core.Response>delete()<T> reactor.core.publisher.Mono<T>delete(Class<T> responseType)<T> reactor.core.publisher.Mono<T>delete(javax.ws.rs.core.GenericType<T> responseType)reactor.core.publisher.Mono<javax.ws.rs.core.Response>get()<T> reactor.core.publisher.Mono<T>get(Class<T> responseType)<T> reactor.core.publisher.Mono<T>get(javax.ws.rs.core.GenericType<T> responseType)reactor.core.publisher.Mono<javax.ws.rs.core.Response>head()reactor.core.publisher.Mono<javax.ws.rs.core.Response>method(String name)<T> reactor.core.publisher.Mono<T>method(String name, Class<T> responseType)reactor.core.publisher.Mono<javax.ws.rs.core.Response>method(String name, javax.ws.rs.client.Entity<?> entity)<T> reactor.core.publisher.Mono<T>method(String name, javax.ws.rs.client.Entity<?> entity, Class<T> responseType)<T> reactor.core.publisher.Mono<T>method(String name, javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<T> responseType)<T> reactor.core.publisher.Mono<T>method(String name, javax.ws.rs.core.GenericType<T> responseType)reactor.core.publisher.Mono<javax.ws.rs.core.Response>options()<T> reactor.core.publisher.Mono<T>options(Class<T> responseType)<T> reactor.core.publisher.Mono<T>options(javax.ws.rs.core.GenericType<T> responseType)reactor.core.publisher.Mono<javax.ws.rs.core.Response>post(javax.ws.rs.client.Entity<?> entity)<T> reactor.core.publisher.Mono<T>post(javax.ws.rs.client.Entity<?> entity, Class<T> clazz)<T> reactor.core.publisher.Mono<T>post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<T> type)reactor.core.publisher.Mono<javax.ws.rs.core.Response>put(javax.ws.rs.client.Entity<?> entity)<T> reactor.core.publisher.Mono<T>put(javax.ws.rs.client.Entity<?> entity, Class<T> clazz)<T> reactor.core.publisher.Mono<T>put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<T> type)protected <T> reactor.core.publisher.Mono<T>toPublisher(CompletionStage<T> completable)reactor.core.publisher.Mono<javax.ws.rs.core.Response>trace()<T> reactor.core.publisher.Mono<T>trace(Class<T> responseType)<T> reactor.core.publisher.Mono<T>trace(javax.ws.rs.core.GenericType<T> responseType)
-
-
-
Constructor Detail
-
MonoRxInvokerImpl
public MonoRxInvokerImpl(ClientInvocationBuilder builder)
-
-
Method Detail
-
toPublisher
protected <T> reactor.core.publisher.Mono<T> toPublisher(CompletionStage<T> completable)
- Specified by:
toPublisherin classPublisherRxInvokerImpl
-
get
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> get()
- Specified by:
getin interfaceMonoRxInvoker- Specified by:
getin interfacePublisherRxInvoker- Specified by:
getin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
getin classPublisherRxInvokerImpl
-
get
public <T> reactor.core.publisher.Mono<T> get(Class<T> responseType)
- Specified by:
getin interfaceMonoRxInvoker- Specified by:
getin interfacePublisherRxInvoker- Specified by:
getin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
getin classPublisherRxInvokerImpl
-
get
public <T> reactor.core.publisher.Mono<T> get(javax.ws.rs.core.GenericType<T> responseType)
- Specified by:
getin interfaceMonoRxInvoker- Specified by:
getin interfacePublisherRxInvoker- Specified by:
getin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
getin classPublisherRxInvokerImpl
-
put
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> put(javax.ws.rs.client.Entity<?> entity)
- Specified by:
putin interfaceMonoRxInvoker- Specified by:
putin interfacePublisherRxInvoker- Specified by:
putin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
putin classPublisherRxInvokerImpl
-
put
public <T> reactor.core.publisher.Mono<T> put(javax.ws.rs.client.Entity<?> entity, Class<T> clazz)- Specified by:
putin interfaceMonoRxInvoker- Specified by:
putin interfacePublisherRxInvoker- Specified by:
putin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
putin classPublisherRxInvokerImpl
-
put
public <T> reactor.core.publisher.Mono<T> put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<T> type)- Specified by:
putin interfaceMonoRxInvoker- Specified by:
putin interfacePublisherRxInvoker- Specified by:
putin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
putin classPublisherRxInvokerImpl
-
post
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> post(javax.ws.rs.client.Entity<?> entity)
- Specified by:
postin interfaceMonoRxInvoker- Specified by:
postin interfacePublisherRxInvoker- Specified by:
postin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
postin classPublisherRxInvokerImpl
-
post
public <T> reactor.core.publisher.Mono<T> post(javax.ws.rs.client.Entity<?> entity, Class<T> clazz)- Specified by:
postin interfaceMonoRxInvoker- Specified by:
postin interfacePublisherRxInvoker- Specified by:
postin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
postin classPublisherRxInvokerImpl
-
post
public <T> reactor.core.publisher.Mono<T> post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<T> type)- Specified by:
postin interfaceMonoRxInvoker- Specified by:
postin interfacePublisherRxInvoker- Specified by:
postin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
postin classPublisherRxInvokerImpl
-
delete
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> delete()
- Specified by:
deletein interfaceMonoRxInvoker- Specified by:
deletein interfacePublisherRxInvoker- Specified by:
deletein interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
deletein classPublisherRxInvokerImpl
-
delete
public <T> reactor.core.publisher.Mono<T> delete(Class<T> responseType)
- Specified by:
deletein interfaceMonoRxInvoker- Specified by:
deletein interfacePublisherRxInvoker- Specified by:
deletein interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
deletein classPublisherRxInvokerImpl
-
delete
public <T> reactor.core.publisher.Mono<T> delete(javax.ws.rs.core.GenericType<T> responseType)
- Specified by:
deletein interfaceMonoRxInvoker- Specified by:
deletein interfacePublisherRxInvoker- Specified by:
deletein interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
deletein classPublisherRxInvokerImpl
-
head
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> head()
- Specified by:
headin interfaceMonoRxInvoker- Specified by:
headin interfacePublisherRxInvoker- Specified by:
headin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
headin classPublisherRxInvokerImpl
-
options
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> options()
- Specified by:
optionsin interfaceMonoRxInvoker- Specified by:
optionsin interfacePublisherRxInvoker- Specified by:
optionsin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
optionsin classPublisherRxInvokerImpl
-
options
public <T> reactor.core.publisher.Mono<T> options(Class<T> responseType)
- Specified by:
optionsin interfaceMonoRxInvoker- Specified by:
optionsin interfacePublisherRxInvoker- Specified by:
optionsin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
optionsin classPublisherRxInvokerImpl
-
options
public <T> reactor.core.publisher.Mono<T> options(javax.ws.rs.core.GenericType<T> responseType)
- Specified by:
optionsin interfaceMonoRxInvoker- Specified by:
optionsin interfacePublisherRxInvoker- Specified by:
optionsin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
optionsin classPublisherRxInvokerImpl
-
trace
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> trace()
- Specified by:
tracein interfaceMonoRxInvoker- Specified by:
tracein interfacePublisherRxInvoker- Specified by:
tracein interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
tracein classPublisherRxInvokerImpl
-
trace
public <T> reactor.core.publisher.Mono<T> trace(Class<T> responseType)
- Specified by:
tracein interfaceMonoRxInvoker- Specified by:
tracein interfacePublisherRxInvoker- Specified by:
tracein interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
tracein classPublisherRxInvokerImpl
-
trace
public <T> reactor.core.publisher.Mono<T> trace(javax.ws.rs.core.GenericType<T> responseType)
- Specified by:
tracein interfaceMonoRxInvoker- Specified by:
tracein interfacePublisherRxInvoker- Specified by:
tracein interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
tracein classPublisherRxInvokerImpl
-
method
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> method(String name)
- Specified by:
methodin interfaceMonoRxInvoker- Specified by:
methodin interfacePublisherRxInvoker- Specified by:
methodin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
methodin classPublisherRxInvokerImpl
-
method
public <T> reactor.core.publisher.Mono<T> method(String name, Class<T> responseType)
- Specified by:
methodin interfaceMonoRxInvoker- Specified by:
methodin interfacePublisherRxInvoker- Specified by:
methodin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
methodin classPublisherRxInvokerImpl
-
method
public <T> reactor.core.publisher.Mono<T> method(String name, javax.ws.rs.core.GenericType<T> responseType)
- Specified by:
methodin interfaceMonoRxInvoker- Specified by:
methodin interfacePublisherRxInvoker- Specified by:
methodin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
methodin classPublisherRxInvokerImpl
-
method
public reactor.core.publisher.Mono<javax.ws.rs.core.Response> method(String name, javax.ws.rs.client.Entity<?> entity)
- Specified by:
methodin interfaceMonoRxInvoker- Specified by:
methodin interfacePublisherRxInvoker- Specified by:
methodin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
methodin classPublisherRxInvokerImpl
-
method
public <T> reactor.core.publisher.Mono<T> method(String name, javax.ws.rs.client.Entity<?> entity, Class<T> responseType)
- Specified by:
methodin interfaceMonoRxInvoker- Specified by:
methodin interfacePublisherRxInvoker- Specified by:
methodin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
methodin classPublisherRxInvokerImpl
-
method
public <T> reactor.core.publisher.Mono<T> method(String name, javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<T> responseType)
- Specified by:
methodin interfaceMonoRxInvoker- Specified by:
methodin interfacePublisherRxInvoker- Specified by:
methodin interfacejavax.ws.rs.client.RxInvoker<org.reactivestreams.Publisher<?>>- Overrides:
methodin classPublisherRxInvokerImpl
-
-