process/examples/watch-live.php

<?php

include dirname(__DIR__) . "/vendor/autoload.php";

use Amp\Process\StreamedProcess;

Amp\Loop::run(function () {
    $process = new StreamedProcess("echo 1; sleep 1; echo 2; sleep 1; echo 3; exit 42");
    $process->start();

    while ($chunk = yield $process->read()) {
        echo $chunk;
    }

    $code = yield $process->join();
    echo "Process exited with {$code}.\n";
});