# File lib/em/iterator.rb, line 51 def initialize(list, concurrency = 1) raise ArgumentError, 'argument must be an array' unless list.respond_to?(:to_a) @list = list.to_a.dup @concurrency = concurrency @started = false @ended = false end