Class ReactorNettyClientHttpEngine
java.lang.Object
org.jboss.resteasy.client.jaxrs.engines.ReactorNettyClientHttpEngine
- All Implemented Interfaces:
ClientHttpEngine
,AsyncClientHttpEngine
,ReactiveClientHttpEngine
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.jboss.resteasy.client.jaxrs.engines.AsyncClientHttpEngine
AsyncClientHttpEngine.ResultExtractor<T>
-
Constructor Summary
ConstructorDescriptionReactorNettyClientHttpEngine
(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider) ReactorNettyClientHttpEngine
(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider, Boolean useResponseFinalize) ReactorNettyClientHttpEngine
(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider, Duration requestTimeout) ReactorNettyClientHttpEngine
(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider, Duration requestTimeout, Boolean useResponseFinalize) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
reactor.core.publisher.Mono
How the reactive implementation handles errors.<T> reactor.core.publisher.Mono<T>
Needed for Client.getHostnameVerifier()Needed for Client.getSslContext();jakarta.ws.rs.core.Response
invoke
(jakarta.ws.rs.client.Invocation request) <T> reactor.core.publisher.Mono<T>
just
(T t) <T> Future<T>
submit
(ClientInvocation request, boolean buffered, jakarta.ws.rs.client.InvocationCallback<T> callback, AsyncClientHttpEngine.ResultExtractor<T> extractor) Submits an asynchronous request.<K> CompletableFuture<K>
submit
(ClientInvocation request, boolean buffered, AsyncClientHttpEngine.ResultExtractor<K> extractor, ExecutorService executorService) Submits an asynchronous request.<T> reactor.core.publisher.Mono<T>
submitRx
(ClientInvocation request, boolean buffered, AsyncClientHttpEngine.ResultExtractor<T> extractor) This is the main bridge from RestEasy to a reactive implementation.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.jboss.resteasy.client.jaxrs.engines.AsyncClientHttpEngine
submit
Methods inherited from interface org.jboss.resteasy.client.jaxrs.ClientHttpEngine
isFollowRedirects, setFollowRedirects
-
Constructor Details
-
ReactorNettyClientHttpEngine
public ReactorNettyClientHttpEngine(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider) -
ReactorNettyClientHttpEngine
public ReactorNettyClientHttpEngine(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider, Duration requestTimeout) -
ReactorNettyClientHttpEngine
public ReactorNettyClientHttpEngine(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider, Boolean useResponseFinalize) -
ReactorNettyClientHttpEngine
-
-
Method Details
-
submitRx
public <T> reactor.core.publisher.Mono<T> submitRx(ClientInvocation request, boolean buffered, AsyncClientHttpEngine.ResultExtractor<T> extractor) Description copied from interface:ReactiveClientHttpEngine
This is the main bridge from RestEasy to a reactive implementation.- Specified by:
submitRx
in interfaceReactiveClientHttpEngine
-
fromCompletionStage
- Specified by:
fromCompletionStage
in interfaceReactiveClientHttpEngine
-
just
public <T> reactor.core.publisher.Mono<T> just(T t) - Specified by:
just
in interfaceReactiveClientHttpEngine
-
error
Description copied from interface:ReactiveClientHttpEngine
How the reactive implementation handles errors.- Specified by:
error
in interfaceReactiveClientHttpEngine
-
submit
public <T> Future<T> submit(ClientInvocation request, boolean buffered, jakarta.ws.rs.client.InvocationCallback<T> callback, AsyncClientHttpEngine.ResultExtractor<T> extractor) Description copied from interface:AsyncClientHttpEngine
Submits an asynchronous request.- Specified by:
submit
in interfaceAsyncClientHttpEngine
- Type Parameters:
T
- type- Parameters:
request
- Requestbuffered
- buffer the response?callback
- Optional callback receiving the result, which is run inside the io-thread. may be null.extractor
- ResultExtractor for extracting a result out of a ClientResponse. Is run inside the io-thread- Returns:
- Future with the result or Exception
-
submit
public <K> CompletableFuture<K> submit(ClientInvocation request, boolean buffered, AsyncClientHttpEngine.ResultExtractor<K> extractor, ExecutorService executorService) Description copied from interface:AsyncClientHttpEngine
Submits an asynchronous request.- Specified by:
submit
in interfaceAsyncClientHttpEngine
- Type Parameters:
K
- type- Parameters:
request
- Requestbuffered
- buffer the response?extractor
- ResultExtractor for extracting a result out of a ClientResponse. Is run inside the io-threadexecutorService
- the executor to use for asynchronous execution- Returns:
CompletableFuture
with the result or Exception
-
getSslContext
Description copied from interface:ClientHttpEngine
Needed for Client.getSslContext();- Specified by:
getSslContext
in interfaceClientHttpEngine
- Returns:
SSLContext
-
getHostnameVerifier
Description copied from interface:ClientHttpEngine
Needed for Client.getHostnameVerifier()- Specified by:
getHostnameVerifier
in interfaceClientHttpEngine
- Returns:
HostnameVerifier
-
invoke
public jakarta.ws.rs.core.Response invoke(jakarta.ws.rs.client.Invocation request) - Specified by:
invoke
in interfaceClientHttpEngine
-
close
public void close()- Specified by:
close
in interfaceClientHttpEngine
-