protocolReader = $protocolReader; $this->protocolWriter = $protocolWriter; $this->idGenerator = new IdGenerator; } /** * Sends a request to the client and returns a promise that is resolved with the result or rejected with the error * * @param string $method The method to call * @param array|object $params The method parameters * @return Promise Resolved with the result of the request or rejected with an error */ public function request(string $method, $params): Promise { $id = $this->idGenerator->generate(); return call( /** * @return Generator> */ function () use ($id, $method, $params): Generator { yield $this->protocolWriter->write( new Message( new Request($id, $method, (object) $params), ), ); $deferred = new Deferred(); $listener = function (Message $msg) use ($id, $deferred, &$listener): void { /** * @psalm-suppress UndefinedPropertyFetch * @psalm-suppress MixedArgument */ if ($msg->body && Response::isResponse($msg->body) && $msg->body->id === $id ) { // Received a response $this->protocolReader->removeListener('message', $listener); if (SuccessResponse::isSuccessResponse($msg->body)) { $deferred->resolve($msg->body->result); } else { $deferred->fail($msg->body->error); } } }; $this->protocolReader->on('message', $listener); return $deferred->promise(); }, ); } /** * Sends a notification to the client * * @param string $method The method to call * @param array|object $params The method parameters */ public function notify(string $method, $params): void { $this->protocolWriter->write( new Message( new Notification($method, (object)$params), ), ); } }