Sha256: 3fcd6cdd288d4559b4bb069d2d1be96a645b94a1ecd7c51a36b06036ad225dfb
Contents?: true
Size: 863 Bytes
Versions: 11
Compression:
Stored size: 863 Bytes
Contents
# frozen_string_literal: true
module PgEventstore
module Web
module Subscriptions
module WithState
class SetCollection
# @!attribute connection
# @return [PgEventstore::Connection]
attr_reader :connection
private :connection
# @param connection [PgEventstore::Connection]
# @param state [String]
def initialize(connection, state:)
@connection = connection
@state = state
end
# @return [Array<String>]
def names
@set_collection ||= subscription_queries.set_collection(@state)
end
private
# @return [PgEventstore::SubscriptionQueries]
def subscription_queries
SubscriptionQueries.new(connection)
end
end
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems