Sha256: 223bd5c963c007f12a55c493026415633d9eba1e76195c354d32248045b0903a

Contents?: true

Size: 152 Bytes

Versions: 3

Compression:

Stored size: 152 Bytes

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