Class: PgEventstore::Web::Subscriptions::SetCollection
- Inherits:
-
Object
- Object
- PgEventstore::Web::Subscriptions::SetCollection
- Defined in:
- lib/pg_eventstore/web/subscriptions/set_collection.rb,
sig/pg_eventstore/web/subscriptions/set_collection.rbs
Instance Attribute Summary collapse
-
#connection ⇒ PgEventstore::Connection
Returns the value of attribute connection.
Instance Method Summary collapse
-
#initialize(connection) ⇒ SetCollection
constructor
@param
connection. - #names ⇒ Array<String>
- #subscription_queries ⇒ PgEventstore::SubscriptionQueries
- #subscriptions_set_queries ⇒ PgEventstore::SubscriptionsSetQueries
Constructor Details
#initialize(connection) ⇒ SetCollection
@param connection
13 14 15 |
# File 'lib/pg_eventstore/web/subscriptions/set_collection.rb', line 13 def initialize(connection) @connection = connection end |
Instance Attribute Details
#connection ⇒ PgEventstore::Connection
Returns the value of attribute connection.
9 10 11 |
# File 'lib/pg_eventstore/web/subscriptions/set_collection.rb', line 9 def connection @connection end |
Instance Method Details
#names ⇒ Array<String>
18 19 20 |
# File 'lib/pg_eventstore/web/subscriptions/set_collection.rb', line 18 def names @names ||= (subscription_queries.set_collection | subscriptions_set_queries.set_names).sort end |
#subscription_queries ⇒ PgEventstore::SubscriptionQueries
25 26 27 |
# File 'lib/pg_eventstore/web/subscriptions/set_collection.rb', line 25 def subscription_queries SubscriptionQueries.new(connection, QueryStrategy::Foreground.new(connection)) end |
#subscriptions_set_queries ⇒ PgEventstore::SubscriptionsSetQueries
30 31 32 |
# File 'lib/pg_eventstore/web/subscriptions/set_collection.rb', line 30 def subscriptions_set_queries SubscriptionsSetQueries.new(connection) end |