path = $path; } public function createBodyStream(): InputStream { $handlePromise = \function_exists('Amp\File\openFile') ? openFile($this->path, "r") : open($this->path, "r"); return new class($handlePromise) implements InputStream { /** @var Promise */ private $promise; /** @var InputStream|null */ private $stream; public function __construct(Promise $promise) { $this->promise = $promise; $this->promise->onResolve(function ($error, $stream) { if ($error) { return; } $this->stream = $stream; }); } public function read(): Promise { if (!$this->stream) { return call(function () { /** @var InputStream $stream */ $stream = yield $this->promise; return $stream->read(); }); } return $this->stream->read(); } }; } public function getHeaders(): Promise { return new Success([]); } public function getBodyLength(): Promise { return \function_exists('Amp\File\getSize') ? getSize($this->path) : size($this->path); } }