Sha256: 7a130b0baaaa4c1a56c6d328d6d5b18155b55085d46b49ff1e63e1f99b40f03e

Contents?: true

Size: 320 Bytes

Versions: 1

Compression:

Stored size: 320 Bytes

Contents

# frozen_string_literal: true

module ActiveWebhook
  module Queueing
    class SyncronousAdapter < BaseAdapter
      def call
        subscriptions.each do |subscription|
          self.class.fulfill_subscription subscription: subscription, **context
        end
        subscriptions.count
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
active_webhook-1.0.0 lib/active_webhook/queueing/syncronous_adapter.rb