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