org.apache.cxf.jaxrs.reactor.client

Class ReactorInvokerImpl

java.lang.Object

org.apache.cxf.jaxrs.reactor.client.ReactorInvokerImpl

All Implemented Interfaces:

javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>, ReactorInvoker

public class ReactorInvokerImpl
extends Object
implements ReactorInvoker

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	delete()
<R> reactor.core.publisher.Mono<R>	delete(Class<R> responseType)
<R> reactor.core.publisher.Mono<R>	delete(javax.ws.rs.core.GenericType<R> genericType)
<T> reactor.core.publisher.Flux<T>	deleteFlux(Class<T> responseType)
<T> reactor.core.publisher.Flux<T>	flux(String name, Class<T> responseType)
<T> reactor.core.publisher.Flux<T>	flux(String name, javax.ws.rs.client.Entity<?> entity, Class<T> responseType)
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	get()
<R> reactor.core.publisher.Mono<R>	get(Class<R> responseType)
<R> reactor.core.publisher.Mono<R>	get(javax.ws.rs.core.GenericType<R> genericType)
<T> reactor.core.publisher.Flux<T>	getFlux(Class<T> responseType)
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	head()
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	method(String name)
<R> reactor.core.publisher.Mono<R>	method(String name, Class<R> responseType)
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	method(String name, javax.ws.rs.client.Entity<?> entity)
<R> reactor.core.publisher.Mono<R>	method(String name, javax.ws.rs.client.Entity<?> entity, Class<R> responseType)
<R> reactor.core.publisher.Mono<R>	method(String name, javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> genericType)
<R> reactor.core.publisher.Mono<R>	method(String name, javax.ws.rs.core.GenericType<R> genericType)
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	options()
<R> reactor.core.publisher.Mono<R>	options(Class<R> responseType)
<R> reactor.core.publisher.Mono<R>	options(javax.ws.rs.core.GenericType<R> genericType)
<T> reactor.core.publisher.Flux<T>	optionsFlux(Class<T> responseType)
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	post(javax.ws.rs.client.Entity<?> entity)
<R> reactor.core.publisher.Mono<R>	post(javax.ws.rs.client.Entity<?> entity, Class<R> responseType)
<R> reactor.core.publisher.Mono<R>	post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> genericType)
<T> reactor.core.publisher.Flux<T>	postFlux(javax.ws.rs.client.Entity<?> entity, Class<T> responseType)
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	put(javax.ws.rs.client.Entity<?> entity)
<R> reactor.core.publisher.Mono<R>	put(javax.ws.rs.client.Entity<?> entity, Class<R> responseType)
<R> reactor.core.publisher.Mono<R>	put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> genericType)
<T> reactor.core.publisher.Flux<T>	putFlux(javax.ws.rs.client.Entity<?> entity, Class<T> responseType)
reactor.core.publisher.Mono<javax.ws.rs.core.Response>	trace()
<R> reactor.core.publisher.Mono<R>	trace(Class<R> responseType)
<R> reactor.core.publisher.Mono<R>	trace(javax.ws.rs.core.GenericType<R> genericType)
<T> reactor.core.publisher.Flux<T>	traceFlux(Class<T> responseType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

get

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> get()

Specified by:

get in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

get in interface ReactorInvoker

get

public <R> reactor.core.publisher.Mono<R> get(Class<R> responseType)

Specified by:

get in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

get in interface ReactorInvoker

getFlux

public <T> reactor.core.publisher.Flux<T> getFlux(Class<T> responseType)

Specified by:

getFlux in interface ReactorInvoker

get

public <R> reactor.core.publisher.Mono<R> get(javax.ws.rs.core.GenericType<R> genericType)

Specified by:

get in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

get in interface ReactorInvoker

put

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> put(javax.ws.rs.client.Entity<?> entity)

Specified by:

put in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

put in interface ReactorInvoker

put

public <R> reactor.core.publisher.Mono<R> put(javax.ws.rs.client.Entity<?> entity,
                                              Class<R> responseType)

Specified by:

put in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

put in interface ReactorInvoker

putFlux

public <T> reactor.core.publisher.Flux<T> putFlux(javax.ws.rs.client.Entity<?> entity,
                                                  Class<T> responseType)

Specified by:

putFlux in interface ReactorInvoker

put

public <R> reactor.core.publisher.Mono<R> put(javax.ws.rs.client.Entity<?> entity,
                                              javax.ws.rs.core.GenericType<R> genericType)

Specified by:

put in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

put in interface ReactorInvoker

post

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> post(javax.ws.rs.client.Entity<?> entity)

Specified by:

post in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

post in interface ReactorInvoker

post

public <R> reactor.core.publisher.Mono<R> post(javax.ws.rs.client.Entity<?> entity,
                                               Class<R> responseType)

Specified by:

post in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

post in interface ReactorInvoker

postFlux

public <T> reactor.core.publisher.Flux<T> postFlux(javax.ws.rs.client.Entity<?> entity,
                                                   Class<T> responseType)

Specified by:

postFlux in interface ReactorInvoker

post

public <R> reactor.core.publisher.Mono<R> post(javax.ws.rs.client.Entity<?> entity,
                                               javax.ws.rs.core.GenericType<R> genericType)

Specified by:

post in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

post in interface ReactorInvoker

delete

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> delete()

Specified by:

delete in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

delete in interface ReactorInvoker

delete

public <R> reactor.core.publisher.Mono<R> delete(Class<R> responseType)

Specified by:

delete in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

delete in interface ReactorInvoker

deleteFlux

public <T> reactor.core.publisher.Flux<T> deleteFlux(Class<T> responseType)

Specified by:

deleteFlux in interface ReactorInvoker

delete

public <R> reactor.core.publisher.Mono<R> delete(javax.ws.rs.core.GenericType<R> genericType)

Specified by:

delete in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

delete in interface ReactorInvoker

head

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> head()

Specified by:

head in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

head in interface ReactorInvoker

options

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> options()

Specified by:

options in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

options in interface ReactorInvoker

options

public <R> reactor.core.publisher.Mono<R> options(Class<R> responseType)

Specified by:

options in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

options in interface ReactorInvoker

optionsFlux

public <T> reactor.core.publisher.Flux<T> optionsFlux(Class<T> responseType)

Specified by:

optionsFlux in interface ReactorInvoker

options

public <R> reactor.core.publisher.Mono<R> options(javax.ws.rs.core.GenericType<R> genericType)

Specified by:

options in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

options in interface ReactorInvoker

trace

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> trace()

Specified by:

trace in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

trace in interface ReactorInvoker

trace

public <R> reactor.core.publisher.Mono<R> trace(Class<R> responseType)

Specified by:

trace in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

trace in interface ReactorInvoker

traceFlux

public <T> reactor.core.publisher.Flux<T> traceFlux(Class<T> responseType)

Specified by:

traceFlux in interface ReactorInvoker

trace

public <R> reactor.core.publisher.Mono<R> trace(javax.ws.rs.core.GenericType<R> genericType)

Specified by:

trace in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

trace in interface ReactorInvoker

method

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> method(String name)

Specified by:

method in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

method in interface ReactorInvoker

method

public <R> reactor.core.publisher.Mono<R> method(String name,
                                                 Class<R> responseType)

Specified by:

method in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

method in interface ReactorInvoker

method

public <R> reactor.core.publisher.Mono<R> method(String name,
                                                 javax.ws.rs.core.GenericType<R> genericType)

Specified by:

method in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

method in interface ReactorInvoker

method

public reactor.core.publisher.Mono<javax.ws.rs.core.Response> method(String name,
                                                                     javax.ws.rs.client.Entity<?> entity)

Specified by:

method in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

method in interface ReactorInvoker

method

public <R> reactor.core.publisher.Mono<R> method(String name,
                                                 javax.ws.rs.client.Entity<?> entity,
                                                 Class<R> responseType)

Specified by:

method in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

method in interface ReactorInvoker

flux

public <T> reactor.core.publisher.Flux<T> flux(String name,
                                               javax.ws.rs.client.Entity<?> entity,
                                               Class<T> responseType)

Specified by:

flux in interface ReactorInvoker

flux

public <T> reactor.core.publisher.Flux<T> flux(String name,
                                               Class<T> responseType)

Specified by:

flux in interface ReactorInvoker

method

public <R> reactor.core.publisher.Mono<R> method(String name,
                                                 javax.ws.rs.client.Entity<?> entity,
                                                 javax.ws.rs.core.GenericType<R> genericType)

Specified by:

method in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Mono<?>>

Specified by:

method in interface ReactorInvoker