Server : ApacheSystem : Linux host.digitalbabaji.in 4.18.0-513.11.1.el8_9.x86_64 #1 SMP Wed Jan 17 02:00:40 EST 2024 x86_64 User : addictionfreeind ( 1003) PHP Version : 7.2.34 Disable Function : exec,passthru,shell_exec,system Directory : /home/addictionfreeind/www/admin1/vendor/amphp/parallel/lib/Worker/Internal/ |
Upload File : |
<?php
namespace Amp\Parallel\Worker\Internal;
use Amp\ByteStream;
use Amp\Parallel\Context\Context;
use Amp\Parallel\Context\Process;
use Amp\Promise;
use function Amp\call;
class WorkerProcess implements Context
{
/** @var Process */
private $process;
public function __construct($script, array $env = [], string $binary = null)
{
$this->process = new Process($script, null, $env, $binary);
}
public function receive(): Promise
{
return $this->process->receive();
}
public function send($data): Promise
{
return $this->process->send($data);
}
public function isRunning(): bool
{
return $this->process->isRunning();
}
public function start(): Promise
{
return call(function () {
$result = yield $this->process->start();
$stdout = $this->process->getStdout();
$stdout->unreference();
$stderr = $this->process->getStderr();
$stderr->unreference();
ByteStream\pipe($stdout, ByteStream\getStdout());
ByteStream\pipe($stderr, ByteStream\getStderr());
return $result;
});
}
public function kill(): void
{
if ($this->process->isRunning()) {
$this->process->kill();
}
}
public function join(): Promise
{
return $this->process->join();
}
}