Module: AggregateStreams::Controls::MessageData::Input

Defined in:
lib/aggregate_streams/controls/message_data.rb

Class Method Summary collapse

Class Method Details

.alternate(type: nil, data: nil) ⇒ Object 



17
18
19
20
21
 
# File 'lib/aggregate_streams/controls/message_data.rb', line 17

def self.alternate(type: nil, data: nil)
  metadata = Metadata::Input.alternate

  Read.example(type: type, data: data, metadata: metadata)
end

.example(type: nil, data: nil, metadata: nil, **metadata_args) ⇒ Object 



7
8
9
10
11
12
13
14
15
 
# File 'lib/aggregate_streams/controls/message_data.rb', line 7

def self.example(type: nil, data: nil, metadata: nil, **metadata_args)
  metadata ||= Metadata::Input.example(**metadata_args)

  message_data = Read.example(type: type, data: data, metadata: metadata)
  message_data.stream_name = metadata[:stream_name]
  message_data.position = metadata[:position]
  message_data.global_position = metadata[:global_position]
  message_data
end