File tree Expand file tree Collapse file tree 2 files changed +5
-7
lines changed
Expand file tree Collapse file tree 2 files changed +5
-7
lines changed Original file line number Diff line number Diff line change @@ -199,7 +199,8 @@ private function tick(): void
199199 {
200200 $ this ->processSSEStream ();
201201 $ this ->processProgress ();
202- $ this ->tryResumeFiber ();
202+ $ this ->processFiber ();
203+
203204 usleep (1000 ); // 1ms
204205 }
205206
@@ -275,7 +276,7 @@ private function processProgress(): void
275276 }
276277 }
277278
278- private function tryResumeFiber (): void
279+ private function processFiber (): void
279280 {
280281 if (null === $ this ->activeFiber || !$ this ->activeFiber ->isSuspended ()) {
281282 return ;
Original file line number Diff line number Diff line change @@ -192,11 +192,8 @@ private function spawnProcess(): void
192192 private function tick (): void
193193 {
194194 $ this ->processInput ();
195-
196195 $ this ->processProgress ();
197-
198- $ this ->tryResumeFiber ();
199-
196+ $ this ->processFiber ();
200197 $ this ->processStderr ();
201198
202199 usleep (1000 ); // 1ms
@@ -248,7 +245,7 @@ private function processInput(): void
248245 }
249246 }
250247
251- private function tryResumeFiber (): void
248+ private function processFiber (): void
252249 {
253250 if (null === $ this ->activeFiber || !$ this ->activeFiber ->isSuspended ()) {
254251 return ;
You can’t perform that action at this time.
0 commit comments