Class: EventStoreClient::Client

Inherits:
Object
  • Object
show all
Includes:
Configuration
Defined in:
lib/event_store_client/client.rb

Constant Summary collapse

NoCallMethodOnSubscriber = 
Class.new(StandardError)
WrongExpectedEventVersion = 
Class.new(StandardError)

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Configuration

#config

Instance Attribute Details

#connection ⇒ Object

rubocop:enable Metrics/CyclomaticComplexity



45
46
47
 
# File 'lib/event_store_client/client.rb', line 45

def connection
  @connection
end

Instance Method Details

rubocop:disable Metrics/CyclomaticComplexity

Raises:

  • (ArgumentError) 


35
36
37
38
39
40
41
42
 
# File 'lib/event_store_client/client.rb', line 35

def link_to(stream:, events:, options: {})
  raise ArgumentError if !stream || stream == ''
  raise ArgumentError if events.nil? || (events.is_a?(Array) && events.empty?)
  res = connection.link_to(stream, events, options: options)
  raise WrongExpectedEventVersion.new(e.message) if res.failure?

  res.success?
end

#listen(wait: false) ⇒ Object 



30
31
32
 
# File 'lib/event_store_client/client.rb', line 30

def listen(wait: false)
  broker.call(@subscriptions, wait: wait)
end

#publish(stream:, events:, options: {}) ⇒ Object

Raises:



12
13
14
15
 
# File 'lib/event_store_client/client.rb', line 12

def publish(stream:, events:, options: {})
  res = connection.append_to_stream(stream, events, options: options)
  raise WrongExpectedEventVersion.new(e.message) if res.failure?
end

#read(stream, options: {}) ⇒ Object 



17
18
19
20
21
22
23
 
# File 'lib/event_store_client/client.rb', line 17

def read(stream, options: {})
  if options[:all]
    connection.read_all_from_stream(stream, options: options)
  else
    connection.read(stream, options: options)
  end
end

#subscribe(subscriber, to: []) ⇒ Object

Raises:



25
26
27
28
 
# File 'lib/event_store_client/client.rb', line 25

def subscribe(subscriber, to: [])
  raise NoCallMethodOnSubscriber unless subscriber.respond_to?(:call)
  @subscriptions.create(subscriber, to)
end