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