Contents

class Datapipes
  # Tube takes effect data which passes through pipe.
  #
  # Build your own tube logic in `run` method.
  class Tube
    include Composable

    def run_all(data)
      @accumulated ||= [self]

      @accumulated.reduce(data) do |d, tube|
        if tube.accept? d
          tube.run(d)
        else
          d
        end
      end
    end

    def accept?(data)
      true
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
datapipes-0.0.4	lib/datapipes/tube.rb