shell-like pipeline in Ruby DSL (ver. 2)

pipeline.rb

#!/usr/bin/env ruby

require 'open3'

module PipeOperator
  refine Array do
    def |(x)
      PipeLine.new(self) | x
    end
  end

  refine String do
    def |(x)
      PipeLine.new(self) | x
    end
  end
end

class PipeLine
  def initialize(cmd)
    @cmds = [cmd]
  end

  def |(cmd)
    @cmds << (Array === cmd ? cmd : [cmd])
    self
  end

  def execute
    Open3.pipeline(*@cmds)
  end

  def self.run
    yield.execute
  end
end

if __FILE__ == $0
  using PipeOperator

  PipeLine::run { ['yes', 'Yo!'] | 'nl' | ['head', '-n', '10'] }
end