@@ -316,7 +316,7 @@ public static function stream(iterable $responses, float $timeout = null): \Gene
316316 }
317317
318318 $ lastActivity = microtime (true );
319- $ enlapsedTimeout = 0 ;
319+ $ elapsedTimeout = 0 ;
320320
321321 while (true ) {
322322 $ hasActivity = false ;
@@ -338,15 +338,15 @@ public static function stream(iterable $responses, float $timeout = null): \Gene
338338 } elseif (!isset ($ multi ->openHandles [$ j ])) {
339339 unset($ responses [$ j ]);
340340 continue ;
341- } elseif ($ enlapsedTimeout >= $ timeoutMax ) {
341+ } elseif ($ elapsedTimeout >= $ timeoutMax ) {
342342 $ multi ->handlesActivity [$ j ] = [new ErrorChunk ($ response ->offset , sprintf ('Idle timeout reached for "%s". ' , $ response ->getInfo ('url ' )))];
343343 } else {
344344 continue ;
345345 }
346346
347347 while ($ multi ->handlesActivity [$ j ] ?? false ) {
348348 $ hasActivity = true ;
349- $ enlapsedTimeout = 0 ;
349+ $ elapsedTimeout = 0 ;
350350
351351 if (\is_string ($ chunk = array_shift ($ multi ->handlesActivity [$ j ]))) {
352352 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
380380 }
381381 } elseif ($ chunk instanceof ErrorChunk) {
382382 unset($ responses [$ j ]);
383- $ enlapsedTimeout = $ timeoutMax ;
383+ $ elapsedTimeout = $ timeoutMax ;
384384 } elseif ($ chunk instanceof FirstChunk) {
385385 if ($ response ->logger ) {
386386 $ info = $ response ->getInfo ();
@@ -448,11 +448,11 @@ public static function stream(iterable $responses, float $timeout = null): \Gene
448448 continue ;
449449 }
450450
451- if (-1 === self ::select ($ multi , min ($ timeoutMin , $ timeoutMax - $ enlapsedTimeout ))) {
451+ if (-1 === self ::select ($ multi , min ($ timeoutMin , $ timeoutMax - $ elapsedTimeout ))) {
452452 usleep (min (500 , 1E6 * $ timeoutMin ));
453453 }
454454
455- $ enlapsedTimeout = microtime (true ) - $ lastActivity ;
455+ $ elapsedTimeout = microtime (true ) - $ lastActivity ;
456456 }
457457 }
458458}
0 commit comments