Class: Sequent::Core::StreamRecord
- Inherits:
-
ActiveRecord::Base
- Object
- ActiveRecord::Base
- Sequent::Core::StreamRecord
- Defined in:
- lib/sequent/core/stream_record.rb
Instance Method Summary collapse
Instance Method Details
#event_stream ⇒ Object
25 26 27 |
# File 'lib/sequent/core/stream_record.rb', line 25 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) ⇒ Object
29 30 31 32 33 |
# File 'lib/sequent/core/stream_record.rb', line 29 def event_stream=(data) self.aggregate_type = data.aggregate_type self.aggregate_id = data.aggregate_id self.snapshot_threshold = data.snapshot_threshold end |