Package graphql

Class EngineRunningState

java.lang.Object

graphql.EngineRunningState

@NullMarked
public class EngineRunningState
extends Object

Constructor Summary

Constructors

Constructor	Description
EngineRunningState(ExecutionInput executionInput, Profiler profiler)

Method Summary

Modifier and Type	Method	Description
<U, T> CompletableFuture<U>	compose(CompletableFuture<T> src, Function<? super T,? extends CompletionStage<U>> fn)
CompletableFuture<ExecutionResult>	engineRun(Supplier<CompletableFuture<ExecutionResult>> engineRun)	Only used once outside of this class: when the execution starts
<U, T> CompletableFuture<U>	handle(CompletableFuture<T> src, BiFunction<? super T,Throwable,? extends U> fn)
@Nullable AbortExecutionException	ifCancelledMakeException()
@Nullable Throwable	possibleCancellation(@Nullable Throwable currentThrowable)	if the passed in Throwableis non-null then it is returned as id and if there is no exception then the cancellation state is checked in ExecutionInput.isCancelled() and a AbortExecutionException is made as the returned Throwable
void	throwIfCancelled()	This will abort the execution via throwing AbortExecutionException if the ExecutionInput has been cancelled
void	updateExecutionInput(ExecutionInput executionInput)
<T> CompletableFuture<T>	whenComplete(CompletableFuture<T> src, BiConsumer<? super T,? super Throwable> fn)

Methods inherited from class java.lang.Object

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

Constructor Details

EngineRunningState

public EngineRunningState(ExecutionInput executionInput,
 Profiler profiler)

Method Details

handle

public <U,
T> CompletableFuture<U> handle(CompletableFuture<T> src,
 BiFunction<? super T,Throwable,? extends U> fn)

whenComplete

public <T> CompletableFuture<T> whenComplete(CompletableFuture<T> src,
 BiConsumer<? super T,? super Throwable> fn)

compose

public <U,
T> CompletableFuture<U> compose(CompletableFuture<T> src,
 Function<? super T,? extends CompletionStage<U>> fn)

updateExecutionInput

public void updateExecutionInput(ExecutionInput executionInput)

engineRun

public CompletableFuture<ExecutionResult> engineRun(Supplier<CompletableFuture<ExecutionResult>> engineRun)

Only used once outside of this class: when the execution starts

throwIfCancelled

public void throwIfCancelled()
                      throws AbortExecutionException

This will abort the execution via throwing AbortExecutionException if the ExecutionInput has been cancelled

Throws:

AbortExecutionException

possibleCancellation

public @Nullable Throwable possibleCancellation(@Nullable Throwable currentThrowable)

if the passed in Throwableis non-null then it is returned as id and if there is no exception then the cancellation state is checked in ExecutionInput.isCancelled() and a AbortExecutionException is made as the returned Throwable

Parameters:

currentThrowable - the current exception state

Returns:

a current throwable or a cancellation exception or null if none are in error

ifCancelledMakeException

public @Nullable AbortExecutionException ifCancelledMakeException()

Returns:

a AbortExecutionException if the current operation has been cancelled via ExecutionInput.cancel()