Contents

# A basic source is list type. it produces a value in several times.
# Use `produce` method to emit data to pipe.
#
class List < Datapipes::Source
  def run
    (1..10).each {|i| produce(i) }
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

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