lib/graphql/subscriptions/anycable_subscriptions.rb
# An event was triggered.
# Re-evaluate all subscribed queries and push the data over ActionCable.
An event was triggered.
Re-evaluate all subscribed queries and push the data over ActionCable.
An event was triggered . Re - evaluate all subscribed queries and push the data over ActionCable .
def execute_all(event, object)
        redis.smembers(EVENT_PREFIX + event.topic).each do |subscription_id|
          next unless redis.exists?(SUBSCRIPTION_PREFIX + subscription_id)
          execute(subscription_id, event, object)
        end
      end
def execute_all ( event , object ) redis . smembers ( EVENT_PREFIX + event . topic ) . each do | subscription_id | next unless redis . exists? ( SUBSCRIPTION_PREFIX + subscription_id ) execute ( subscription_id , event , object ) end end
An event was triggered.
An event was triggered .
event
object