@@ -10,7 +10,7 @@ built on top of [ReactPHP](https://reactphp.org/).
10
10
Let's say you crawl a page and find that you need to send 100 HTTP requests to
11
11
following pages which each takes ` 0.2s ` . You can either send them all
12
12
sequentially (taking around ` 20s ` ) or you can use
13
- [ ReactPHP] ( https://reactphp.org ) to concurrently request all your pages at the
13
+ [ ReactPHP] ( https://reactphp.org/ ) to concurrently request all your pages at the
14
14
same time. This works perfectly fine for a small number of operations, but
15
15
sending an excessive number of requests can either take up all resources on your
16
16
side or may get you banned by the remote side as it sees an unreasonable number
@@ -84,12 +84,14 @@ $q = new Clue\React\Mq\Queue(3, null, function ($url) use ($browser) {
84
84
foreach ($urls as $url) {
85
85
$q($url)->then(function (Psr\Http\Message\ResponseInterface $response) use ($url) {
86
86
echo $url . ': ' . $response->getBody()->getSize() . ' bytes' . PHP_EOL;
87
+ }, function (Exception $e) {
88
+ echo 'Error: ' . $e->getMessage() . PHP_EOL;
87
89
});
88
90
}
89
91
90
92
```
91
93
92
- See also the [ examples] ( examples ) .
94
+ See also the [ examples] ( examples/ ) .
93
95
94
96
## Usage
95
97
@@ -292,6 +294,8 @@ $promise = Queue::all(3, $urls, function ($url) use ($browser) {
292
294
293
295
$promise->then(function (array $responses) {
294
296
echo 'All ' . count($responses) . ' successful!' . PHP_EOL;
297
+ }, function (Exception $e) {
298
+ echo 'Error: ' . $e->getMessage() . PHP_EOL;
295
299
});
296
300
```
297
301
@@ -368,6 +372,8 @@ $promise = Queue::any(3, $urls, function ($url) use ($browser) {
368
372
369
373
$promise->then(function (ResponseInterface $response) {
370
374
echo 'First response: ' . $response->getBody() . PHP_EOL;
375
+ }, function (Exception $e) {
376
+ echo 'Error: ' . $e->getMessage() . PHP_EOL;
371
377
});
372
378
```
373
379
0 commit comments