@@ 52-60 (lines=9) @@ | ||
49 | ->set(CURLOPT_TIMEOUT, self::CURL_TIMEOUT) |
|
50 | ->set(CURLOPT_RETURNTRANSFER, true); |
|
51 | $requests = &$this->requests; |
|
52 | $this->queue->addListener('complete', function (Event $event) use (&$requests) { |
|
53 | $this->counter++; |
|
54 | $url = curl_getinfo($event->request->getHandle(), CURLINFO_EFFECTIVE_URL); |
|
55 | $this->log($url); |
|
56 | $this->logProgress(); |
|
57 | if ($next = array_pop($requests)) { |
|
58 | $event->queue->attach($next); |
|
59 | } |
|
60 | }); |
|
61 | } |
|
62 | ||
63 | /** |
@@ 108-116 (lines=9) @@ | ||
105 | ->set(CURLOPT_RETURNTRANSFER, true); |
|
106 | ||
107 | $requests = &$this->requests; |
|
108 | $this->queue->addListener('complete', function (Event $event) use (&$requests) { |
|
109 | $this->counter++; |
|
110 | $url = curl_getinfo($event->request->getHandle(), CURLINFO_EFFECTIVE_URL); |
|
111 | $this->log($url); |
|
112 | $this->logProgress(); |
|
113 | if ($next = array_pop($requests)) { |
|
114 | $event->queue->attach($next); |
|
115 | } |
|
116 | }); |
|
117 | } |
|
118 | ||
119 | /** |