Package com.here.platform.data.client.http

Class RequestResponseHandler

java.lang.Object

com.here.platform.data.client.http.RequestResponseHandler

All Implemented Interfaces:

HttpHandler

public class RequestResponseHandler
extends Object
implements HttpHandler

Constructor Summary

Constructors

Constructor	Description
RequestResponseHandler(com.typesafe.config.Config config, RetryPolicyType retryPolicyType, scala.Option<String> userAgentSuffix, scala.Option<RequestExecutor> requestExecutorOpt, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
static org.apache.pekko.http.scaladsl.model.HttpRequest	appendRequestId(org.apache.pekko.http.scaladsl.model.HttpRequest request, String requestId, String operationId)
static String	baseUserAgent()
scala.concurrent.Future<org.apache.pekko.http.scaladsl.model.HttpResponse>	executeRequest(RequestTemplate requestTemplate, InternalSettings settings)
scala.concurrent.Future<org.apache.pekko.http.scaladsl.model.HttpResponse>	executeRequestWithBody(RequestTemplate requestTemplate, InternalSettings settings, scala.Function0<scala.Option<org.apache.pekko.http.scaladsl.model.RequestEntity>> prepareBody)
final scala.concurrent.Future<org.apache.pekko.http.scaladsl.model.HttpRequest>	prepareRequest(RequestTemplate requestTemplate, InternalSettings settings)
final RequestExecutor	requestExecutor()
org.apache.pekko.http.scaladsl.model.ResponseEntity	resumeRequestOnSourceFailure(RequestTemplate requestTemplate, InternalSettings settings, org.apache.pekko.http.scaladsl.model.ResponseEntity entity, ByteRange bytesMask)

Methods inherited from class java.lang.Object

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

Constructor Details

RequestResponseHandler

public RequestResponseHandler(com.typesafe.config.Config config,
 RetryPolicyType retryPolicyType,
 scala.Option<String> userAgentSuffix,
 scala.Option<RequestExecutor> requestExecutorOpt,
 ClientExecutionContext clientExecutionContext)

Method Details

baseUserAgent

public static String baseUserAgent()

appendRequestId

public static org.apache.pekko.http.scaladsl.model.HttpRequest appendRequestId(org.apache.pekko.http.scaladsl.model.HttpRequest request,
 String requestId,
 String operationId)

requestExecutor

public final RequestExecutor requestExecutor()

prepareRequest

public final scala.concurrent.Future<org.apache.pekko.http.scaladsl.model.HttpRequest> prepareRequest(RequestTemplate requestTemplate,
 InternalSettings settings)

executeRequest

public scala.concurrent.Future<org.apache.pekko.http.scaladsl.model.HttpResponse> executeRequest(RequestTemplate requestTemplate,
 InternalSettings settings)

Specified by:

executeRequest in interface HttpHandler

executeRequestWithBody

public scala.concurrent.Future<org.apache.pekko.http.scaladsl.model.HttpResponse> executeRequestWithBody(RequestTemplate requestTemplate,
 InternalSettings settings,
 scala.Function0<scala.Option<org.apache.pekko.http.scaladsl.model.RequestEntity>> prepareBody)

Specified by:

executeRequestWithBody in interface HttpHandler

resumeRequestOnSourceFailure

public org.apache.pekko.http.scaladsl.model.ResponseEntity resumeRequestOnSourceFailure(RequestTemplate requestTemplate,
 InternalSettings settings,
 org.apache.pekko.http.scaladsl.model.ResponseEntity entity,
 ByteRange bytesMask)

Specified by:

resumeRequestOnSourceFailure in interface HttpHandler