Contents

module Rworkflow
  # Disable pushing back indefinitely
  class Worker
    def initialize(*args)
      super
      @__pushed_back = []
    end

    def pushed_back
      return @__pushed_back
    end

    def push_back(objects)
      @__pushed_back.concat(objects)
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
rworkflow-0.7.3	lib/rworkflow/minitest/worker.rb
rworkflow-0.7.2	lib/rworkflow/minitest/worker.rb
rworkflow-0.7.1	lib/rworkflow/minitest/worker.rb
rworkflow-0.7.0	lib/rworkflow/minitest/worker.rb
rworkflow-0.6.5	lib/rworkflow/minitest/worker.rb
rworkflow-0.6.4	lib/rworkflow/minitest/worker.rb
rworkflow-0.6.3	lib/rworkflow/minitest/worker.rb
rworkflow-0.6.2	lib/rworkflow/minitest/worker.rb
rworkflow-0.6.1	lib/rworkflow/minitest/worker.rb