class Sequent::Core::StreamRecord
Public Instance Methods
event_stream()
click to toggle source
# File lib/sequent/core/stream_record.rb, line 26 def event_stream EventStream.new( aggregate_type: aggregate_type, aggregate_id: aggregate_id, snapshot_threshold: snapshot_threshold, stream_record_id: id, ) end
event_stream=(data)
click to toggle source
# File lib/sequent/core/stream_record.rb, line 35 def event_stream=(data) self.aggregate_type = data.aggregate_type self.aggregate_id = data.aggregate_id self.snapshot_threshold = data.snapshot_threshold end