Class DefaultAsyncOverReactiveHttpClient

java.lang.Object

io.micronaut.http.client.DefaultAsyncOverReactiveHttpClient

All Implemented Interfaces:

LifeCycle<AsyncHttpClient>, AsyncHttpClient, Closeable, AutoCloseable

@Internal
public class DefaultAsyncOverReactiveHttpClient
extends Object
implements AsyncHttpClient

Default AsyncHttpClient implementation that adapts a reactive HttpClient.

Since:

5.0

Author:

Denis Stepanov

Constructor Summary

Constructors

Constructor	Description
DefaultAsyncOverReactiveHttpClient(HttpClient httpClient)

Method Summary

Modifier and Type	Method	Description
void	close()	Delegates to LifeCycle.stop().
<I,O,E> CompletionStage<HttpResponse<O>>	exchange(HttpRequest<I> request, @Nullable Argument<O> bodyType, Argument<E> errorType)	Perform an HTTP request for the given request object emitting the full HTTP response and converting the response body to the specified type.
protected final HttpClient	getHttpClient()
boolean	isRunning()
DefaultAsyncOverReactiveHttpClient	start()	Starts the lifecyle component.
DefaultAsyncOverReactiveHttpClient	stop()	Stops the life cycle component.

Methods inherited from class Object

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

Methods inherited from interface AsyncHttpClient

exchange, exchange, exchange, exchange, exchange, retrieve, retrieve, retrieve, retrieve, retrieve

Methods inherited from interface LifeCycle

refresh

Constructor Details

DefaultAsyncOverReactiveHttpClient

public DefaultAsyncOverReactiveHttpClient(HttpClient httpClient)

Parameters:

httpClient - The delegate client

Method Details

exchange

public <I,O,E> CompletionStage<HttpResponse<O>> exchange(HttpRequest<I> request,
 @Nullable Argument<O> bodyType,
 Argument<E> errorType)

Description copied from interface: AsyncHttpClient

Perform an HTTP request for the given request object emitting the full HTTP response and converting the response body to the specified type.

Specified by:

exchange in interface AsyncHttpClient

Type Parameters:

I - The request body type

O - The response body type

E - The error type

Parameters:

request - The HttpRequest to execute

bodyType - The body type

errorType - The error type

Returns:

A CompletionStage that completes with the full HttpResponse

start

public DefaultAsyncOverReactiveHttpClient start()

Description copied from interface: LifeCycle

Starts the lifecyle component.

Specified by:

start in interface LifeCycle<AsyncHttpClient>

Returns:

This lifecycle component

stop

public DefaultAsyncOverReactiveHttpClient stop()

Description copied from interface: LifeCycle

Stops the life cycle component.

Specified by:

stop in interface LifeCycle<AsyncHttpClient>

Returns:

This lifecycle component

isRunning

public boolean isRunning()

Specified by:

isRunning in interface LifeCycle<AsyncHttpClient>

Returns:

Whether the component is running

close

public void close()

Description copied from interface: LifeCycle

Delegates to LifeCycle.stop().

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface LifeCycle<AsyncHttpClient>

getHttpClient

protected final HttpClient getHttpClient()

Returns:

The underlying HttpClient