class EventMachine::Iterator

to accomodate the new concurrency level.
Change the concurrency of this iterator. Workers will automatically be spawned or destroyed

def concurrency=(val)
  old = @concurrency
  @concurrency = val
  spawn_workers if val > old and @started and !@ended
end