contextFactory = new ThreadContextFactory(ipcHub: $ipcHub); } else { $this->contextFactory = new ProcessContextFactory(ipcHub: $ipcHub); } } /** * @param string|non-empty-list $script * * @throws ContextException */ public function start(string|array $script, ?Cancellation $cancellation = null): Context { $context = $this->contextFactory->start($script, $cancellation); if ($context instanceof ProcessContext) { $stdout = $context->getStdout(); $stdout->unreference(); $stderr = $context->getStderr(); $stderr->unreference(); async(ByteStream\pipe(...), $stdout, ByteStream\getStdout())->ignore(); async(ByteStream\pipe(...), $stderr, ByteStream\getStderr())->ignore(); } return $context; } }