Package de.chojo.nexus

Class NexusRestImpl

java.lang.Object

de.chojo.nexus.NexusRestImpl

All Implemented Interfaces:

NexusRest

public class NexusRestImpl
extends Object
implements NexusRest

Implementation of a rest client

Constructor Summary

Constructors

Constructor	Description
NexusRestImpl(HttpClient http, ScheduledExecutorService executorService, String host, Map<String,String> header)	Create a new nexus rest client

Method Summary

Modifier and Type	Method	Description
<T> T	delete(URI uri)
<T> CompletableFuture<T>	deleteAsync(URI uri)
<T> T	dispatch(Callable<T> callable)
<T> CompletableFuture<T>	dispatchAsync(Callable<T> callable)
<T> T	getAndMap(URI uri, Class<T> result)	Send a request and map the result body
<T> T	getAndMap(org.apache.hc.core5.net.URIBuilder uri, Class<T> result)	Send a request and map the result body
<T> List<T>	getAndMapList(URI uri, Class<T> result)	Send a request and map the result body
<T> CompletableFuture<T>	getAsyncAndMap(URI uri, Class<T> result)	Send an asynchronous request to the uri and map the result body
<T> CompletableFuture<T>	getAsyncAndMap(org.apache.hc.core5.net.URIBuilder uri, Class<T> result)	Send an asynchronous request to the uri and map the result body
<T> CompletableFuture<List<T>>	getAsyncAndMapList(URI uri, Class<T> result)	Send an asynchronous request to the uri and map the result body
CompletableFuture<byte[]>	getAsyncBytes(URI uri)
CompletableFuture<InputStream>	getAsyncStream(URI uri)
CompletableFuture<Path>	getAsyncToFile(URI uri, @Nullable Path path)
byte[]	getBytes(URI uri)
InputStream	getStream(URI uri)
Path	getToFile(URI uri, @Nullable Path path)
HttpClient	http()	Get the http client
com.fasterxml.jackson.databind.ObjectMapper	objectMapper()	Get the object mapper
org.apache.hc.core5.net.URIBuilder	uri()	Get a pre configured uri builder
V1	v1()

Methods inherited from class java.lang.Object

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

Constructor Details

NexusRestImpl

public NexusRestImpl(HttpClient http,
 ScheduledExecutorService executorService,
 String host,
 Map<String,String> header)

Create a new nexus rest client

Parameters:

http - http client

executorService - executor service

header -

Method Details

http

public HttpClient http()

Get the http client

Returns:

http client

uri

public org.apache.hc.core5.net.URIBuilder uri()

Get a pre configured uri builder

Returns:

new uri builder

objectMapper

public com.fasterxml.jackson.databind.ObjectMapper objectMapper()

Get the object mapper

Returns:

object mapper

getAsyncAndMap

public <T> CompletableFuture<T> getAsyncAndMap(org.apache.hc.core5.net.URIBuilder uri,
 Class<T> result)

Send an asynchronous request to the uri and map the result body

Type Parameters:

T - result type

Parameters:

uri - uri

result - result class

Returns:

future with result

getAndMap

public <T> T getAndMap(org.apache.hc.core5.net.URIBuilder uri,
 Class<T> result)

Send a request and map the result body

Type Parameters:

T - result type

Parameters:

uri - uri

result - result class

Returns:

result

getAsyncAndMap

public <T> CompletableFuture<T> getAsyncAndMap(URI uri,
 Class<T> result)

Send an asynchronous request to the uri and map the result body

Type Parameters:

T - result type

Parameters:

uri - uri

result - result class

Returns:

future with result

getAndMap

public <T> T getAndMap(URI uri,
 Class<T> result)

Send a request and map the result body

Type Parameters:

T - result type

Parameters:

uri - uri

result - result class

Returns:

result

dispatch

public <T> T dispatch(Callable<T> callable)

dispatchAsync

public <T> CompletableFuture<T> dispatchAsync(Callable<T> callable)

getAsyncAndMapList

public <T> CompletableFuture<List<T>> getAsyncAndMapList(URI uri,
 Class<T> result)

Send an asynchronous request to the uri and map the result body

Type Parameters:

T - result type

Parameters:

uri - uri

result - result class

Returns:

future with result

getAndMapList

public <T> List<T> getAndMapList(URI uri,
 Class<T> result)

Send a request and map the result body

Type Parameters:

T - result type

Parameters:

uri - uri

result - result class

Returns:

result

getBytes

public byte[] getBytes(URI uri)

getAsyncBytes

public CompletableFuture<byte[]> getAsyncBytes(URI uri)

getStream

public InputStream getStream(URI uri)

getAsyncStream

public CompletableFuture<InputStream> getAsyncStream(URI uri)

getToFile

public Path getToFile(URI uri,
 @Nullable
 @Nullable Path path)

getAsyncToFile

public CompletableFuture<Path> getAsyncToFile(URI uri,
 @Nullable
 @Nullable Path path)

v1

public V1 v1()

Specified by:

v1 in interface NexusRest

deleteAsync

public <T> CompletableFuture<T> deleteAsync(URI uri)

delete

public <T> T delete(URI uri)