class GraphQL::Streaming::AssignSubscriptionField::SubscriptionResolve

Public Class Methods

new(subscription_handle, resolve_proc) click to toggle source
# File lib/graphql/streaming/assign_subscription_field.rb, line 24
def initialize(subscription_handle, resolve_proc)
  @subscription_handle = subscription_handle
  @resolve_proc = resolve_proc
end

Public Instance Methods

call(obj, args, ctx) click to toggle source
# File lib/graphql/streaming/assign_subscription_field.rb, line 29
def call(obj, args, ctx)
  subscriber = ctx[:subscriber]
  subscriber && subscriber.register(@subscription_handle, args.to_h)
  @resolve_proc.call(obj, args, ctx)
end