Sha256: 29826e5b4033a4129740da066144825aaa205c1a5129a60fba6fa80efe65d2ff
Contents?: true
Size: 887 Bytes
Versions: 7
Compression:
Stored size: 887 Bytes
Contents
# frozen_string_literal: true
module PgEventstore
module Web
module Subscriptions
class SubscriptionsSet
attr_reader :connection
private :connection
# @param connection [PgEventstore::Connection]
# @param current_set [String, nil]
def initialize(connection, current_set)
@connection = connection
@current_set = current_set
end
# @return [Array<PgEventstore::SubscriptionsSet>]
def subscriptions_set
@subscriptions_set ||= subscriptions_set_queries.find_all(name: @current_set).map do |attrs|
PgEventstore::SubscriptionsSet.new(**attrs)
end
end
private
# @return [PgEventstore::SubscriptionsSetQueries]
def subscriptions_set_queries
SubscriptionsSetQueries.new(connection)
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems