public class FluxRxInvokerImpl extends Object implements FluxRxInvoker
Constructor and Description |
---|
FluxRxInvokerImpl(javax.ws.rs.client.SyncInvoker syncInvoker,
ExecutorService executorService) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<?> |
delete() |
<R> reactor.core.publisher.Flux<?> |
delete(Class<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
delete(javax.ws.rs.core.GenericType<R> responseType) |
reactor.core.publisher.Flux<?> |
get() |
<R> reactor.core.publisher.Flux<?> |
get(Class<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
get(javax.ws.rs.core.GenericType<R> responseType) |
reactor.core.publisher.FluxSink.OverflowStrategy |
getOverflowStrategy() |
reactor.core.publisher.Flux<?> |
head() |
reactor.core.publisher.Flux<?> |
method(String name) |
<R> reactor.core.publisher.Flux<?> |
method(String name,
Class<R> responseType) |
reactor.core.publisher.Flux<?> |
method(String name,
javax.ws.rs.client.Entity<?> entity) |
<R> reactor.core.publisher.Flux<?> |
method(String name,
javax.ws.rs.client.Entity<?> entity,
Class<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
method(String name,
javax.ws.rs.client.Entity<?> entity,
javax.ws.rs.core.GenericType<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
method(String name,
javax.ws.rs.core.GenericType<R> responseType) |
reactor.core.publisher.Flux<?> |
options() |
<R> reactor.core.publisher.Flux<?> |
options(Class<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
options(javax.ws.rs.core.GenericType<R> responseType) |
reactor.core.publisher.Flux<?> |
post(javax.ws.rs.client.Entity<?> entity) |
<R> reactor.core.publisher.Flux<?> |
post(javax.ws.rs.client.Entity<?> entity,
Class<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
post(javax.ws.rs.client.Entity<?> entity,
javax.ws.rs.core.GenericType<R> responseType) |
reactor.core.publisher.Flux<?> |
put(javax.ws.rs.client.Entity<?> entity) |
<R> reactor.core.publisher.Flux<?> |
put(javax.ws.rs.client.Entity<?> entity,
Class<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
put(javax.ws.rs.client.Entity<?> entity,
javax.ws.rs.core.GenericType<R> responseType) |
void |
setOverflowStrategy(reactor.core.publisher.FluxSink.OverflowStrategy overflowStrategy) |
reactor.core.publisher.Flux<?> |
trace() |
<R> reactor.core.publisher.Flux<?> |
trace(Class<R> responseType) |
<R> reactor.core.publisher.Flux<?> |
trace(javax.ws.rs.core.GenericType<R> responseType) |
public FluxRxInvokerImpl(javax.ws.rs.client.SyncInvoker syncInvoker, ExecutorService executorService)
public reactor.core.publisher.Flux<?> get()
get
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> get(Class<R> responseType)
get
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> get(javax.ws.rs.core.GenericType<R> responseType)
get
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> put(javax.ws.rs.client.Entity<?> entity)
put
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> put(javax.ws.rs.client.Entity<?> entity, Class<R> responseType)
put
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> put(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> responseType)
put
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> post(javax.ws.rs.client.Entity<?> entity)
post
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> post(javax.ws.rs.client.Entity<?> entity, Class<R> responseType)
post
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> post(javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> responseType)
post
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> delete()
delete
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> delete(Class<R> responseType)
delete
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> delete(javax.ws.rs.core.GenericType<R> responseType)
delete
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> head()
head
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> options()
options
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> options(Class<R> responseType)
options
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> options(javax.ws.rs.core.GenericType<R> responseType)
options
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> trace()
trace
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> trace(Class<R> responseType)
trace
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> trace(javax.ws.rs.core.GenericType<R> responseType)
trace
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> method(String name)
method
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> method(String name, Class<R> responseType)
method
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> method(String name, javax.ws.rs.core.GenericType<R> responseType)
method
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.Flux<?> method(String name, javax.ws.rs.client.Entity<?> entity)
method
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> method(String name, javax.ws.rs.client.Entity<?> entity, Class<R> responseType)
method
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public <R> reactor.core.publisher.Flux<?> method(String name, javax.ws.rs.client.Entity<?> entity, javax.ws.rs.core.GenericType<R> responseType)
method
in interface javax.ws.rs.client.RxInvoker<reactor.core.publisher.Flux<?>>
public reactor.core.publisher.FluxSink.OverflowStrategy getOverflowStrategy()
getOverflowStrategy
in interface FluxRxInvoker
public void setOverflowStrategy(reactor.core.publisher.FluxSink.OverflowStrategy overflowStrategy)
setOverflowStrategy
in interface FluxRxInvoker
Copyright © 2020 JBoss by Red Hat. All rights reserved.