Class: GraphQL::Streaming::AssignSubscriptionField::SubscriptionResolve

Inherits:

Object

• Object
• GraphQL::Streaming::AssignSubscriptionField::SubscriptionResolve

Defined in:

lib/graphql/streaming/assign_subscription_field.rb

Instance Method Summary

• #call(obj, args, ctx) ⇒ Object
• #initialize(subscription_handle, resolve_proc) ⇒ SubscriptionResolve constructor

  A new instance of SubscriptionResolve.

Constructor Details

#initialize(subscription_handle, resolve_proc) ⇒ SubscriptionResolve

# 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

Instance Method Details

#call(obj, args, ctx) ⇒ Object

# 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