Contents

class LongTask < Datapipes::Source
  def initialize(range)
    @range = range
  end

  def run
    @range.each do |n|
      produce n
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
datapipes-0.1.5	examples/lib/long_task.rb
datapipes-0.1.4	examples/lib/long_task.rb
datapipes-0.1.3	examples/lib/long_task.rb