Package com.google.genai.gaos.utils

Class RecordingClient

java.lang.Object

com.google.genai.gaos.utils.RecordingClient

All Implemented Interfaces:

HTTPClient, AutoCloseable

public final class RecordingClient
extends Object
implements HTTPClient

Constructor Summary

Constructors

Constructor	Description
RecordingClient()

Method Summary

Modifier and Type	Method	Description
RecordingClient	afterResponse(UnaryOperator<HttpResponse<InputStream>> hook)
RecordingClient	beforeRequest(UnaryOperator<HttpRequest> hook)
List<HttpRequest>	requests()
void	reset()
HttpResponse<InputStream>	send(HttpRequest request)	Sends an HTTP request and returns the response.
CompletableFuture<HttpResponse<InputStream>>	sendAsync(HttpRequest request)	Sends an HTTP request asynchronously and returns a response whose body is exposed as an InputStream (the same body type as the synchronous HTTPClient.send(HttpRequest)).

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.genai.gaos.utils.HTTPClient

close, enableDebugLogging, isDebugLoggingEnabled

Constructor Details

RecordingClient

public RecordingClient()

Method Details

send

public HttpResponse<InputStream> send(HttpRequest request)
                               throws IOException

Description copied from interface: HTTPClient

Sends an HTTP request and returns the response.

Note that HttpRequest is immutable. To modify the request use HttpRequest.toBuilder() which copies the request into a builder.

Specified by:

send in interface HTTPClient

Parameters:

request - HTTP request

Returns:

HTTP response

Throws:

IOException

sendAsync

public CompletableFuture<HttpResponse<InputStream>> sendAsync(HttpRequest request)

Description copied from interface: HTTPClient

Sends an HTTP request asynchronously and returns a response whose body is exposed as an InputStream (the same body type as the synchronous HTTPClient.send(HttpRequest)).

The request is dispatched without blocking the calling thread. The returned CompletableFuture completes when the response headers are received — the body is not read at that point — or completes exceptionally if an error occurs during the request or response processing.

Specified by:

sendAsync in interface HTTPClient

Parameters:

request - the HTTP request to send

Returns:

a CompletableFuture containing the HTTP response with an InputStream body

requests

public List<HttpRequest> requests()

beforeRequest

public RecordingClient beforeRequest(UnaryOperator<HttpRequest> hook)

afterResponse

public RecordingClient afterResponse(UnaryOperator<HttpResponse<InputStream>> hook)

reset

public void reset()