Class: PgEventstore::Web::Subscriptions::Subscriptions

Inherits:
Object
  • Object
show all
Defined in:
lib/pg_eventstore/web/subscriptions/subscriptions.rb,
sig/pg_eventstore/web/subscriptions/subscriptions.rbs

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(connection, current_set) ⇒ Subscriptions

@param connection

@param current_set

Parameters:



14
15
16
17
 
# File 'lib/pg_eventstore/web/subscriptions/subscriptions.rb', line 14

def initialize(connection, current_set)
  @connection = connection
  @current_set = current_set
end

Instance Attribute Details

#connection ⇒ PgEventstore::Connection

Returns the value of attribute connection.

Returns:



9
10
11
 
# File 'lib/pg_eventstore/web/subscriptions/subscriptions.rb', line 9

def connection
  @connection
end

Instance Method Details

#subscription_queries ⇒ PgEventstore::SubscriptionQueries

Returns:

  • (PgEventstore::SubscriptionQueries) 


29
30
31
 
# File 'lib/pg_eventstore/web/subscriptions/subscriptions.rb', line 29

def subscription_queries
  SubscriptionQueries.new(connection, QueryStrategy::Foreground.new(connection))
end

#subscriptions ⇒ Array<PgEventstore::Subscription>

Returns:



20
21
22
23
24
 
# File 'lib/pg_eventstore/web/subscriptions/subscriptions.rb', line 20

def subscriptions
  @subscriptions ||= subscription_queries.find_all(set: @current_set).map do |attrs|
    Subscription.new(**attrs)
  end
end