lib/in_threads/filler.rb in in_threads-1.1.1 vs lib/in_threads/filler.rb in in_threads-1.1.2

@@ -32,10 +32,9 @@
     def initialize(enum, extractor_count)
       @extractors = Array.new(extractor_count){ Extractor.new(self) }
       @mutex = Mutex.new
       @filler = Thread.new do
         enum.each do |o|
-          Thread.stop
           synchronize do
             @extractors.each do |extractor|
               extractor.push(o)
             end
           end