Module: MessageStore::EventStore::Controls::Write

Defined in:
lib/message_store/event_store/controls/write.rb

Class Method Summary collapse

Class Method Details

.call(messages = nil, instances: nil, stream_name: nil) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/message_store/event_store/controls/write.rb', line 5

def self.call(messages=nil, instances: nil, stream_name: nil)
  stream_name ||= StreamName.example

  if messages.nil?
    instances ||= 1

    messages = instances.times.map do |position|
      MessageData::Write.example
    end
  else
    messages = Array(messages)
  end

  ::EventStore::HTTP::Write.(messages, stream_name)

  stream_name
end