class EventMachine::Synchrony::Multi
def check_progress(fiber)
def check_progress(fiber) if (@responses[:callback].size + @responses[:errback].size) == @requests.size succeed # continue processing fiber.resume(self) end end
def check_progress(fiber) if (@responses[:callback].size + @responses[:errback].size) == @requests.size succeed # continue processing fiber.resume(self) end end