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