Contents

class Datapipes
  # Tube takes effect data which passes through pipe.
  #
  # Build your own tube logic in `run` method.
  class Tube
    def >>(op2)
      op1 = self
      Tube.new.tap do |o|
        o.define_singleton_method(:run) do |data|
          op2.run(op1.run(data))
        end
      end
    end

    def run(data)
      data
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
datapipes-0.1.3	lib/datapipes/tube.rb
datapipes-0.1.2	lib/datapipes/tube.rb
datapipes-0.1.1	lib/datapipes/tube.rb
datapipes-0.1.0	lib/datapipes/tube.rb