Package com.google.genai.gaos.operations

Class Operations

java.lang.Object

com.google.genai.gaos.operations.Operations

public class Operations
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Operations.AsyncOperation<ResT>	Base interface for all async operations
static interface	Operations.AsyncRequestlessOperation<ResT>	Interface for async operations that don't require a request parameter
static interface	Operations.AsyncRequestOperation<ReqT,ResT>	Interface for async operations that require a request parameter
static final class	Operations.CancellationRelay	Relays cancellation of the future returned to the SDK user to the in-flight HTTP call, releasing its connection.
static interface	Operations.Operation<ResT>	Base interface for all operations
static interface	Operations.RequestlessOperation<ResT>	Interface for operations that don't require a request parameter
static interface	Operations.RequestOperation<ReqT,ResT>	Interface for operations that require a request parameter

Constructor Summary

Constructors

Constructor	Description
Operations()

Method Summary

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	applyBodyReadAsync(CompletableFuture<HttpResponse<InputStream>> transportFuture, Function<HttpResponse<InputStream>,T> handler)	Runs blocking response-body reading and parsing away from the thread that completed the transport future.
static <T> CompletableFuture<T>	relayCancel(CompletableFuture<T> future, Operations.AsyncOperation<?> operation)	Makes cancelling future cancel the operation's in-flight HTTP call.
static Executor	streamCompletionExecutor()

Methods inherited from class java.lang.Object

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

Constructor Details

Operations

public Operations()

Method Details

relayCancel

public static <T> CompletableFuture<T> relayCancel(CompletableFuture<T> future,
 Operations.AsyncOperation<?> operation)

Makes cancelling future cancel the operation's in-flight HTTP call.

streamCompletionExecutor

public static Executor streamCompletionExecutor()

applyBodyReadAsync

public static <T> CompletableFuture<T> applyBodyReadAsync(CompletableFuture<HttpResponse<InputStream>> transportFuture,
 Function<HttpResponse<InputStream>,T> handler)

Runs blocking response-body reading and parsing away from the thread that completed the transport future.