module AggregateStreams::Controls::MessageData::Input
Public Class Methods
alternate(type: nil, data: nil)
click to toggle source
# 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)
click to toggle source
# 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