Contents

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

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rodimus-0.0.1	lib/rodimus/step.rb