Module: GraphQL::Batch

Defined in:
lib/graphql/batch.rb,
lib/graphql/batch/loader.rb,
lib/graphql/batch/version.rb,
lib/graphql/batch/executor.rb,
lib/graphql/batch/setup_multiplex.rb,
lib/graphql/batch/mutation_field_extension.rb

Defined Under Namespace

Classes: Executor, Loader, MutationFieldExtension, NoExecutorError, SetupMultiplex

Constant Summary collapse

BrokenPromiseError =
::Promise::BrokenError
VERSION =
"0.5.0"

Class Method Summary collapse

Class Method Details

.batch(executor_class: GraphQL::Batch::Executor) ⇒ Object



9
10
11
12
13
14
15
16
# File 'lib/graphql/batch.rb', line 9

def self.batch(executor_class: GraphQL::Batch::Executor)
  begin
    GraphQL::Batch::Executor.start_batch(executor_class)
    ::Promise.sync(yield)
  ensure
    GraphQL::Batch::Executor.end_batch
  end
end

.use(schema_defn, executor_class: GraphQL::Batch::Executor) ⇒ Object



18
19
20
21
22
23
24
25
26
27
28
29
30
31
# File 'lib/graphql/batch.rb', line 18

def self.use(schema_defn, executor_class: GraphQL::Batch::Executor)
  instrumentation = GraphQL::Batch::SetupMultiplex.new(schema_defn, executor_class: executor_class)
  schema_defn.instrument(:multiplex, instrumentation)

  if schema_defn.mutation
    require_relative "batch/mutation_field_extension"

    schema_defn.mutation.fields.each do |name, field|
      field.extension(GraphQL::Batch::MutationFieldExtension)
    end
  end

  schema_defn.lazy_resolve(::Promise, :sync)
end