@@ -316,7 +316,7 @@ public static function stream(iterable $responses, float $timeout = null): \Gene
316
316
}
317
317
318
318
$ lastActivity = microtime (true );
319
- $ enlapsedTimeout = 0 ;
319
+ $ elapsedTimeout = 0 ;
320
320
321
321
while (true ) {
322
322
$ hasActivity = false ;
@@ -338,15 +338,15 @@ public static function stream(iterable $responses, float $timeout = null): \Gene
338
338
} elseif (!isset ($ multi ->openHandles [$ j ])) {
339
339
unset($ responses [$ j ]);
340
340
continue ;
341
- } elseif ($ enlapsedTimeout >= $ timeoutMax ) {
341
+ } elseif ($ elapsedTimeout >= $ timeoutMax ) {
342
342
$ multi ->handlesActivity [$ j ] = [new ErrorChunk ($ response ->offset , sprintf ('Idle timeout reached for "%s". ' , $ response ->getInfo ('url ' )))];
343
343
} else {
344
344
continue ;
345
345
}
346
346
347
347
while ($ multi ->handlesActivity [$ j ] ?? false ) {
348
348
$ hasActivity = true ;
349
- $ enlapsedTimeout = 0 ;
349
+ $ elapsedTimeout = 0 ;
350
350
351
351
if (\is_string ($ chunk = array_shift ($ multi ->handlesActivity [$ j ]))) {
352
352
if (null !== $ response ->inflate && false === $ chunk = @inflate_add ($ response ->inflate , $ chunk )) {
@@ -380,7 +380,7 @@ public static function stream(iterable $responses, float $timeout = null): \Gene
380
380
}
381
381
} elseif ($ chunk instanceof ErrorChunk) {
382
382
unset($ responses [$ j ]);
383
- $ enlapsedTimeout = $ timeoutMax ;
383
+ $ elapsedTimeout = $ timeoutMax ;
384
384
} elseif ($ chunk instanceof FirstChunk) {
385
385
if ($ response ->logger ) {
386
386
$ info = $ response ->getInfo ();
@@ -448,11 +448,11 @@ public static function stream(iterable $responses, float $timeout = null): \Gene
448
448
continue ;
449
449
}
450
450
451
- if (-1 === self ::select ($ multi , min ($ timeoutMin , $ timeoutMax - $ enlapsedTimeout ))) {
451
+ if (-1 === self ::select ($ multi , min ($ timeoutMin , $ timeoutMax - $ elapsedTimeout ))) {
452
452
usleep (min (500 , 1E6 * $ timeoutMin ));
453
453
}
454
454
455
- $ enlapsedTimeout = microtime (true ) - $ lastActivity ;
455
+ $ elapsedTimeout = microtime (true ) - $ lastActivity ;
456
456
}
457
457
}
458
458
}
0 commit comments