Module software.sava.rpc

Package software.sava.rpc.json.http.client

Class JsonHttpClient

java.lang.Object

software.sava.rpc.json.http.client.JsonHttpClient

Direct Known Subclasses:

JsonRpcHttpClient

public abstract class JsonHttpClient
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Predicate<HttpResponse<byte[]>>	applyResponse
protected final URI	endpoint
protected final UnaryOperator<HttpRequest.Builder>	extendRequest
protected final HttpClient	httpClient
protected final Duration	requestTimeout

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JsonHttpClient(URI endpoint, HttpClient httpClient, Duration requestTimeout)
protected	JsonHttpClient(URI endpoint, HttpClient httpClient, Duration requestTimeout, UnaryOperator<HttpRequest.Builder> extendRequest, Predicate<HttpResponse<byte[]>> applyResponse)

Method Summary

Modifier and Type	Method	Description
protected static <R> Function<HttpResponse<byte[]>,R>	applyResponse(BiFunction<byte[],systems.comodal.jsoniter.JsonIterator,R> adapter)
protected static <R> Function<HttpResponse<byte[]>,R>	applyResponse(Function<systems.comodal.jsoniter.JsonIterator,R> adapter)
final URI	endpoint()
final HttpClient	httpClient()
protected final HttpRequest	newPostRequest(URI endpoint, Duration requestTimeout, String body)
protected final HttpRequest.Builder	newRequest()
protected final HttpRequest.Builder	newRequest(String path)
protected final HttpRequest.Builder	newRequest(String path, String method, HttpRequest.BodyPublisher bodyPublisher)
protected final HttpRequest.Builder	newRequest(String method, HttpRequest.BodyPublisher bodyPublisher)
protected final HttpRequest.Builder	newRequest(String path, Duration requestTimeout)
protected final HttpRequest.Builder	newRequest(String path, Duration requestTimeout, String method, HttpRequest.BodyPublisher bodyPublisher)
protected final HttpRequest.Builder	newRequest(URI endpoint)
protected final HttpRequest.Builder	newRequest(URI endpoint, String method, HttpRequest.BodyPublisher bodyPublisher)
protected final HttpRequest.Builder	newRequest(URI endpoint, Duration requestTimeout)
protected final HttpRequest.Builder	newRequest(Duration requestTimeout)
protected final HttpRequest.Builder	newRequest(Duration requestTimeout, String method, HttpRequest.BodyPublisher bodyPublisher)
protected final <R> CompletableFuture<R>	sendGetRequest(URI endpoint, Function<HttpResponse<byte[]>,R> parser)
protected final <R> CompletableFuture<R>	sendGetRequest(Function<HttpResponse<byte[]>,R> parser, String path)
protected final <H, R> CompletableFuture<R>	sendGetRequestNoWrap(HttpResponse.BodyHandler<H> bodyHandler, Function<HttpResponse<H>,R> parser, String path)
protected final <H, R> CompletableFuture<R>	sendGetRequestNoWrap(URI endpoint, HttpResponse.BodyHandler<H> bodyHandler, Function<HttpResponse<H>,R> parser)
protected final <R> CompletableFuture<R>	sendGetRequestNoWrap(URI endpoint, Function<HttpResponse<byte[]>,R> parser)
protected final <R> CompletableFuture<R>	sendGetRequestNoWrap(Function<HttpResponse<byte[]>,R> parser, String path)
protected final <R> CompletableFuture<R>	sendPostRequest(URI endpoint, Function<HttpResponse<byte[]>,R> parser, String body)
protected final <R> CompletableFuture<R>	sendPostRequest(URI endpoint, Function<HttpResponse<byte[]>,R> parser, Duration requestTimeout, String body)
protected final <R> CompletableFuture<R>	sendPostRequest(Function<HttpResponse<byte[]>,R> parser, String body)
protected final <R> CompletableFuture<R>	sendPostRequest(Function<HttpResponse<byte[]>,R> parser, Duration requestTimeout, String body)
protected final <H, R> CompletableFuture<R>	sendPostRequestNoWrap(HttpResponse.BodyHandler<H> bodyHandler, Function<HttpResponse<H>,R> parser, String body)
protected final <H, R> CompletableFuture<R>	sendPostRequestNoWrap(HttpResponse.BodyHandler<H> bodyHandler, Function<HttpResponse<H>,R> parser, Duration requestTimeout, String body)
protected final <H, R> CompletableFuture<R>	sendPostRequestNoWrap(URI endpoint, HttpResponse.BodyHandler<H> bodyHandler, Function<HttpResponse<H>,R> parser, String body)
protected final <H, R> CompletableFuture<R>	sendPostRequestNoWrap(URI endpoint, HttpResponse.BodyHandler<H> bodyHandler, Function<HttpResponse<H>,R> parser, Duration requestTimeout, String body)
protected final <R> CompletableFuture<R>	sendPostRequestNoWrap(URI endpoint, Function<HttpResponse<byte[]>,R> parser, String body)
protected final <R> CompletableFuture<R>	sendPostRequestNoWrap(URI endpoint, Function<HttpResponse<byte[]>,R> parser, Duration requestTimeout, String body)
protected final <R> CompletableFuture<R>	sendPostRequestNoWrap(Function<HttpResponse<byte[]>,R> parser, String body)
protected final <R> CompletableFuture<R>	sendPostRequestNoWrap(Function<HttpResponse<byte[]>,R> parser, Duration requestTimeout, String body)
protected <R> Function<HttpResponse<byte[]>,R>	wrapParser(Function<HttpResponse<byte[]>,R> parser)

Methods inherited from class java.lang.Object

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

Field Details

endpoint

protected final URI endpoint

httpClient

protected final HttpClient httpClient

requestTimeout

protected final Duration requestTimeout

extendRequest

protected final UnaryOperator<HttpRequest.Builder> extendRequest

applyResponse

protected final Predicate<HttpResponse<byte[]>> applyResponse

Constructor Details

JsonHttpClient

protected JsonHttpClient(URI endpoint,
 HttpClient httpClient,
 Duration requestTimeout,
 UnaryOperator<HttpRequest.Builder> extendRequest,
 Predicate<HttpResponse<byte[]>> applyResponse)

JsonHttpClient

protected JsonHttpClient(URI endpoint,
 HttpClient httpClient,
 Duration requestTimeout)

Method Details

endpoint

public final URI endpoint()

httpClient

public final HttpClient httpClient()

applyResponse

protected static <R>
Function<HttpResponse<byte[]>,R> applyResponse(Function<systems.comodal.jsoniter.JsonIterator,R> adapter)

applyResponse

protected static <R>
Function<HttpResponse<byte[]>,R> applyResponse(BiFunction<byte[],systems.comodal.jsoniter.JsonIterator,R> adapter)

wrapParser

protected <R> Function<HttpResponse<byte[]>,R> wrapParser(Function<HttpResponse<byte[]>,R> parser)

newRequest

protected final HttpRequest.Builder newRequest(URI endpoint,
 Duration requestTimeout)

newRequest

protected final HttpRequest.Builder newRequest(String path,
 Duration requestTimeout)

newRequest

protected final HttpRequest.Builder newRequest(String path)

newRequest

protected final HttpRequest.Builder newRequest(URI endpoint)

newRequest

protected final HttpRequest.Builder newRequest(Duration requestTimeout)

newRequest

protected final HttpRequest.Builder newRequest()

newRequest

protected final HttpRequest.Builder newRequest(URI endpoint,
 String method,
 HttpRequest.BodyPublisher bodyPublisher)

newRequest

protected final HttpRequest.Builder newRequest(Duration requestTimeout,
 String method,
 HttpRequest.BodyPublisher bodyPublisher)

newRequest

protected final HttpRequest.Builder newRequest(String method,
 HttpRequest.BodyPublisher bodyPublisher)

newRequest

protected final HttpRequest.Builder newRequest(String path,
 Duration requestTimeout,
 String method,
 HttpRequest.BodyPublisher bodyPublisher)

newRequest

protected final HttpRequest.Builder newRequest(String path,
 String method,
 HttpRequest.BodyPublisher bodyPublisher)

newPostRequest

protected final HttpRequest newPostRequest(URI endpoint,
 Duration requestTimeout,
 String body)

sendPostRequest

protected final <R> CompletableFuture<R> sendPostRequest(URI endpoint,
 Function<HttpResponse<byte[]>,R> parser,
 Duration requestTimeout,
 String body)

sendPostRequest

protected final <R> CompletableFuture<R> sendPostRequest(Function<HttpResponse<byte[]>,R> parser,
 Duration requestTimeout,
 String body)

sendPostRequest

protected final <R> CompletableFuture<R> sendPostRequest(Function<HttpResponse<byte[]>,R> parser,
 String body)

sendPostRequest

protected final <R> CompletableFuture<R> sendPostRequest(URI endpoint,
 Function<HttpResponse<byte[]>,R> parser,
 String body)

sendGetRequest

protected final <R> CompletableFuture<R> sendGetRequest(Function<HttpResponse<byte[]>,R> parser,
 String path)

sendGetRequest

protected final <R> CompletableFuture<R> sendGetRequest(URI endpoint,
 Function<HttpResponse<byte[]>,R> parser)

sendPostRequestNoWrap

protected final <R> CompletableFuture<R> sendPostRequestNoWrap(URI endpoint,
 Function<HttpResponse<byte[]>,R> parser,
 Duration requestTimeout,
 String body)

sendPostRequestNoWrap

protected final <R> CompletableFuture<R> sendPostRequestNoWrap(Function<HttpResponse<byte[]>,R> parser,
 Duration requestTimeout,
 String body)

sendPostRequestNoWrap

protected final <R> CompletableFuture<R> sendPostRequestNoWrap(Function<HttpResponse<byte[]>,R> parser,
 String body)

sendPostRequestNoWrap

protected final <R> CompletableFuture<R> sendPostRequestNoWrap(URI endpoint,
 Function<HttpResponse<byte[]>,R> parser,
 String body)

sendGetRequestNoWrap

protected final <R> CompletableFuture<R> sendGetRequestNoWrap(Function<HttpResponse<byte[]>,R> parser,
 String path)

sendGetRequestNoWrap

protected final <R> CompletableFuture<R> sendGetRequestNoWrap(URI endpoint,
 Function<HttpResponse<byte[]>,R> parser)

sendPostRequestNoWrap

protected final <H,
R> CompletableFuture<R> sendPostRequestNoWrap(URI endpoint,
 HttpResponse.BodyHandler<H> bodyHandler,
 Function<HttpResponse<H>,R> parser,
 Duration requestTimeout,
 String body)

sendPostRequestNoWrap

protected final <H,
R> CompletableFuture<R> sendPostRequestNoWrap(HttpResponse.BodyHandler<H> bodyHandler,
 Function<HttpResponse<H>,R> parser,
 Duration requestTimeout,
 String body)

sendPostRequestNoWrap

protected final <H,
R> CompletableFuture<R> sendPostRequestNoWrap(HttpResponse.BodyHandler<H> bodyHandler,
 Function<HttpResponse<H>,R> parser,
 String body)

sendPostRequestNoWrap

protected final <H,
R> CompletableFuture<R> sendPostRequestNoWrap(URI endpoint,
 HttpResponse.BodyHandler<H> bodyHandler,
 Function<HttpResponse<H>,R> parser,
 String body)

sendGetRequestNoWrap

protected final <H,
R> CompletableFuture<R> sendGetRequestNoWrap(HttpResponse.BodyHandler<H> bodyHandler,
 Function<HttpResponse<H>,R> parser,
 String path)

sendGetRequestNoWrap

protected final <H,
R> CompletableFuture<R> sendGetRequestNoWrap(URI endpoint,
 HttpResponse.BodyHandler<H> bodyHandler,
 Function<HttpResponse<H>,R> parser)