Class AbstractAsyncDataFetcher<K,T>

java.lang.Object
io.smallrye.graphql.execution.datafetcher.AbstractDataFetcher<K,T>
io.smallrye.graphql.execution.datafetcher.AbstractAsyncDataFetcher<K,T>
Type Parameters:
K -
T -
All Implemented Interfaces:
graphql.schema.DataFetcher<T>, PlugableBatchableDataFetcher<K,T>, PlugableDataFetcher<T>, org.dataloader.BatchLoaderWithContext<K,T>
Direct Known Subclasses:
CompletionStageDataFetcher, UniDataFetcher

public abstract class AbstractAsyncDataFetcher<K,T> extends AbstractDataFetcher<K,T>
Handle Async calls with Uni, base for Uni and CompletionState Datafetchers
Author:
Phillip Kruger (phillip.kruger@redhat.com)
  • Constructor Details

    • AbstractAsyncDataFetcher

      public AbstractAsyncDataFetcher(io.smallrye.graphql.schema.model.Operation operation, io.smallrye.graphql.schema.model.Type type)
  • Method Details

    • invokeAndTransform

      protected <O> O invokeAndTransform(io.smallrye.graphql.api.Context context, graphql.schema.DataFetchingEnvironment dfe, graphql.execution.DataFetcherResult.Builder<Object> resultBuilder, Object[] transformedArguments) throws Exception
      Specified by:
      invokeAndTransform in class AbstractDataFetcher<K,T>
      Throws:
      Exception
    • handleUserMethodCall

      protected abstract io.smallrye.mutiny.Uni<?> handleUserMethodCall(graphql.schema.DataFetchingEnvironment dfe, Object[] transformedArguments) throws Exception
      Throws:
      Exception
    • invokeFailure

      protected <O> O invokeFailure(graphql.execution.DataFetcherResult.Builder<Object> resultBuilder)
      Specified by:
      invokeFailure in class AbstractDataFetcher<K,T>
    • invokeBatch

      protected CompletionStage<List<T>> invokeBatch(graphql.schema.DataFetchingEnvironment dfe, Object[] arguments)
      Specified by:
      invokeBatch in class AbstractDataFetcher<K,T>
    • handleUserBatchLoad

      protected abstract io.smallrye.mutiny.Uni<List<T>> handleUserBatchLoad(graphql.schema.DataFetchingEnvironment dfe, Object[] arguments) throws Exception
      Throws:
      Exception