Module: Consumer::EventStore::Controls::PositionStream::Write

Defined in:
lib/consumer/event_store/controls/position_stream.rb

Class Method Summary collapse

Class Method Details

.call(stream_name = nil, position: nil) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
 
# File 'lib/consumer/event_store/controls/position_stream.rb', line 6

def self.call(stream_name=nil, position: nil)
  stream_name ||= StreamName.example(type: 'position')
  position ||= 0

  message = PositionStore::Updated.new
  message.position = position

  Messaging::EventStore::Write.(message, stream_name)

  return stream_name
end