ruby_event_store/lib/ruby_event_store/mappers/pipeline_mapper.rb
# frozen_string_literal: true
module RubyEventStore
module Mappers
class PipelineMapper
def initialize(pipeline)
@pipeline = pipeline
end
def event_to_record(event)
pipeline.dump(event)
end
def record_to_event(record)
pipeline.load(record)
end
private
attr_reader :pipeline
end
end
end