module Rodimus

  module Step
    attr_accessor :incoming, :outgoing

    def run
      incoming.each do |row|
        transformed_row = process_row(row)
        handle_output(transformed_row)
      end
      finalize
    end

    private

    # Override this for custom functionality
    def finalize; end

    # Override this for custom functionality
    def handle_output(transformed_row)
      outgoing.puts(transformed_row)
    end

    # Override this for custom functionality
    def process_row(row)
      row.to_s
    end
  end

end