#31 restart process

lib/Process.php

@@ -281,4 +281,23 @@ public function __debugInfo(): array
             'status' => $this->handle ? $this->handle->status : -1,
         ];
     }
+
+    /**
+     * Restart the process.
+     * @param bool $force Whether to kill process or wait finish
+     * @return Promise<Process> new process instance
+     */
+    public function restart($force = false): Promise
+    {
+        return call(function () use ($force) {
+            if ($force) {
+                $this->kill();
+            } else {
+                yield $this->join();
+            }
+            $instance = new static($this->command, $this->cwd, $this->env, $this->options);
+            yield $instance->start();
+            return $instance;
+        });
+    }
 }

test/ProcessTest.php

@@ -382,4 +382,34 @@ public function testDebugInfo()
             $this->assertSame(ProcessStatus::RUNNING, $debug['status']);
         });
     }
+
+    public function testRestart()
+    {
+        Loop::run(function () {
+            $process = $original = new Process(self::CMD_PROCESS_SLOW);
+            yield $process->start();
+            for ($i=0; $i<=1; $i++) {
+                $this->assertTrue($process->isRunning());
+
+                $process = yield $process->restart();
+
+                $this->assertNotSame($process, $original);
+            }
+        });
+    }
+
+    public function testForceRestart()
+    {
+        Loop::run(function () {
+            $process = $original = new Process(self::CMD_PROCESS_SLOW);
+            yield $process->start();
+            for ($i=0; $i<=1; $i++) {
+                $this->assertTrue($process->isRunning());
+
+                $process = yield $process->restart(true);
+
+                $this->assertNotSame($process, $original);
+            }
+        });
+    }
 }