Standalone/ChildProcess/AsynchronousProcessRunner.php 1 location
|
@@ 65-73 (lines=9) @@
|
| 62 |
|
* @param ProcessInterface $process |
| 63 |
|
* @return void |
| 64 |
|
*/ |
| 65 |
|
protected function createProcessDefinition(ProcessInterface $process): void |
| 66 |
|
{ |
| 67 |
|
$reactProcess = $this->processFactory->create($process->getCommand()); |
| 68 |
|
$reactProcess->start($this->loop); |
| 69 |
|
|
| 70 |
|
$reactProcess->stdout->on('data', function ($chunk) { |
| 71 |
|
echo $chunk; |
| 72 |
|
}); |
| 73 |
|
} |
| 74 |
|
} |
| 75 |
|
|
Standalone/ChildProcess/HalfAsynchronousProcessRunner.php 1 location
|
@@ 70-78 (lines=9) @@
|
| 67 |
|
* @param ProcessInterface $process |
| 68 |
|
* @return void |
| 69 |
|
*/ |
| 70 |
|
protected function createProcessDefinition(ProcessInterface $process): void |
| 71 |
|
{ |
| 72 |
|
$reactProcess = $this->processFactory->create($process->getCommand()); |
| 73 |
|
$reactProcess->start($this->loop); |
| 74 |
|
|
| 75 |
|
$reactProcess->stdout->on('data', function ($chunk) { |
| 76 |
|
echo $chunk; |
| 77 |
|
}); |
| 78 |
|
} |
| 79 |
|
} |
| 80 |
|
|