org.jboss.resteasy.client.jaxrs.engines

Class ReactorNettyClientHttpEngine

java.lang.Object

org.jboss.resteasy.client.jaxrs.engines.ReactorNettyClientHttpEngine

All Implemented Interfaces:

ClientHttpEngine, AsyncClientHttpEngine

public class ReactorNettyClientHttpEngine
extends Object
implements AsyncClientHttpEngine

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.resteasy.client.jaxrs.engines.AsyncClientHttpEngine

AsyncClientHttpEngine.ResultExtractor<T>

Constructor Summary

Constructors

Constructor and Description
ReactorNettyClientHttpEngine(reactor.netty.http.client.HttpClient httpClient, io.netty.channel.group.ChannelGroup channelGroup, reactor.netty.resources.ConnectionProvider connectionProvider) Constructor for ReactorNettyClientHttpEngine

Method Summary

Modifier and Type	Method and Description
void	close()
HostnameVerifier	getHostnameVerifier() Needed for Client.getHostnameVerifier()
SSLContext	getSslContext() Needed for Client.getSslContext();
javax.ws.rs.core.Response	invoke(javax.ws.rs.client.Invocation request)
<T> CompletableFuture<T>	submit(ClientInvocation request, boolean buffered, AsyncClientHttpEngine.ResultExtractor<T> extractor, ExecutorService executorService) Submits an asynchronous request.
<T> Future<T>	submit(ClientInvocation request, boolean buffered, javax.ws.rs.client.InvocationCallback<T> callback, AsyncClientHttpEngine.ResultExtractor<T> extractor) Submits an asynchronous request.

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

Constructor Detail

ReactorNettyClientHttpEngine

public ReactorNettyClientHttpEngine(reactor.netty.http.client.HttpClient httpClient,
                                    io.netty.channel.group.ChannelGroup channelGroup,
                                    reactor.netty.resources.ConnectionProvider connectionProvider)

Constructor for ReactorNettyClientHttpEngine

Parameters:

httpClient - The HttpClient instance to be used by this AsyncClientHttpEngine

channelGroup - The ChannelGroup instance used by the provided HttpClient

connectionProvider - The ConnectionProvider instance used to create the provided HttpClient

Method Detail

submit

public <T> Future<T> submit(ClientInvocation request,
                            boolean buffered,
                            javax.ws.rs.client.InvocationCallback<T> callback,
                            AsyncClientHttpEngine.ResultExtractor<T> extractor)

Description copied from interface: AsyncClientHttpEngine

Submits an asynchronous request.

Specified by:

submit in interface AsyncClientHttpEngine

Type Parameters:

T - type

Parameters:

request - Request

buffered - 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 <T> CompletableFuture<T> submit(ClientInvocation request,
                                       boolean buffered,
                                       AsyncClientHttpEngine.ResultExtractor<T> extractor,
                                       ExecutorService executorService)

Description copied from interface: AsyncClientHttpEngine

Submits an asynchronous request.

Specified by:

submit in interface AsyncClientHttpEngine

Type Parameters:

T - type

Parameters:

request - Request

buffered - buffer the response?

extractor - ResultExtractor for extracting a result out of a ClientResponse. Is run inside the io-thread

executorService - the executor to use for asynchronous execution

Returns:

CompletableFuture with the result or Exception

getSslContext

public SSLContext getSslContext()

Description copied from interface: ClientHttpEngine

Needed for Client.getSslContext();

Specified by:

getSslContext in interface ClientHttpEngine

Returns:

SSLContext

getHostnameVerifier

public HostnameVerifier getHostnameVerifier()

Description copied from interface: ClientHttpEngine

Needed for Client.getHostnameVerifier()

Specified by:

getHostnameVerifier in interface ClientHttpEngine

Returns:

HostnameVerifier

invoke

public javax.ws.rs.core.Response invoke(javax.ws.rs.client.Invocation request)

Specified by:

invoke in interface ClientHttpEngine

close

public void close()

Specified by:

close in interface ClientHttpEngine