class EventStoreClient::Subscription

Attributes

name[R]
observed_streams[R]
stream[R]
subscriber[R]

Public Class Methods

new(subscriber, service:, event_types:) click to toggle source
# File lib/event_store_client/subscription.rb, line 9
def initialize(subscriber, service:, event_types:)
  subscriber_class =
    if subscriber.class.name == 'Class'
      subscriber.name
    else
      subscriber.class.name
    end
  @name = subscriber_class.to_s
  @name = "#{service}-" + @name if service != ''
  @subscriber = subscriber
  @stream = name
  @observed_streams = event_types.reduce([]) { |r, type| r << "$et-#{type}" }
end