We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0b701c2 commit 134612bCopy full SHA for 134612b
1 file changed
src/PipeGoTask.php
@@ -70,6 +70,10 @@ private function start()
70
$task = make(PipeIPCSender::class, ['process' => $this->process]);
71
while (true) {
72
[$method, $payload, $flag, $returnChannel] = $this->taskChannel->pop();
73
+ // check if channel is closed
74
+ if ($method === null) {
75
+ break;
76
+ }
77
$this->lock->lock();
78
try {
79
$result = $task->call($method, $payload, $flag);
0 commit comments