em-синхронность с использованием http.get и итераторов, вызывающих не может дать в корне ошибка волокна

Очень простой случай, когда я получаю ошибку root Fiber.

require 'em-synchrony'
require 'em-synchrony/em-http'

urls = %w{http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com}
EM.synchrony do

  EM::Synchrony::Iterator.new(urls, 2).each(
      proc { |url, iter|

        EM::HttpRequest.new(url).get
        iter.next
      }
  )
end

Я могу использовать здесь асинхронный, но не HTTP-запрос синхронизации.

1 ответ

Решение

Похоже, что если я собираюсь использовать запрос на получение синхронизации, я должен использовать FiberIterator.

require 'em-synchrony'
require 'em-synchrony/em-http'
require "em-synchrony/fiber_iterator"

urls = %w{http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com http://www.google.com}
EM.synchrony do


  EM::Synchrony::FiberIterator.new(urls, 2).each(
      proc { |url|

        EM::HttpRequest.new(url).get

      }
  )
end
Другие вопросы по тегам