class EventStoreClient::CatchUpSubscription
Attributes
filter[R]
position[RW]
subscriber[R]
Public Class Methods
name(subscriber)
click to toggle source
# File lib/event_store_client/catch_up_subscription.rb, line 25 def self.name(subscriber) subscriber.class.to_s end
new(subscriber, filter: nil, position: nil)
click to toggle source
# File lib/event_store_client/catch_up_subscription.rb, line 31 def initialize(subscriber, filter: nil, position: nil) @filter = filter @subscriber = subscriber @position = position @position ||= { commit_position: 0, prepare_position: 0 } @without_system_events = true end
Public Instance Methods
name()
click to toggle source
# File lib/event_store_client/catch_up_subscription.rb, line 21 def name self.class.name(subscriber) end
options()
click to toggle source
# File lib/event_store_client/catch_up_subscription.rb, line 8 def options { filter: @filter, without_system_events: @without_system_events, all: { position: { commit_position: position[:commit_position], prepare_position: position[:prepare_position] } } }.compact end