{

/**

private $metadataTypes = [

'google.rpc.retryinfo-bin' => RetryInfo::class,

'google.rpc.badrequest-bin' => BadRequest::class

];

/**

private function handleResponse($response)

{

if ($response instanceof PagedListResponse) {

$response = $response->getPage()->getResponseObject();

}

if ($response instanceof Message) {

return $this->serializer->encodeMessage($response);

}

if ($response instanceof OperationResponse) {

return $response;

}

if ($response instanceof ServerStream) {

return $this->handleStream($response);

}

return null;

}

/**

private function handleStream(ServerStream $response)

{

try {

foreach ($response->readAll() as $count => $result) {

$res = $this->serializer->encodeMessage($result);

yield $res;

}

} catch (\Exception $ex) {

throw $this->convertToGoogleException($ex);

}

}

/**

private function convertToGoogleException(\Exception $ex): ServiceException

{

switch ($ex->getCode()) {

case Code::INVALID_ARGUMENT:

$exception = Exception\BadRequestException::class;

break;

case Code::NOT_FOUND:

case Code::UNIMPLEMENTED:

$exception = Exception\NotFoundException::class;

break;

case Code::ALREADY_EXISTS:

$exception = Exception\ConflictException::class;

break;

case Code::FAILED_PRECONDITION:

$exception = Exception\FailedPreconditionException::class;

break;

case Code::UNKNOWN:

$exception = Exception\ServerException::class;

break;

case Code::INTERNAL:

$exception = Exception\ServerException::class;

break;

case Code::ABORTED:

$exception = Exception\AbortedException::class;

break;

case Code::DEADLINE_EXCEEDED:

$exception = Exception\DeadlineExceededException::class;

break;

default:

$exception = Exception\ServiceException::class;

break;

}

$metadata = [];

if (method_exists($ex, 'getMetadata') && $ex->getMetadata()) {

foreach ($ex->getMetadata() as $type => $binaryValue) {

if (!isset($this->metadataTypes[$type])) {

continue;

}

$metadataElement = new $this->metadataTypes[$type]();

$metadataElement->mergeFromString($binaryValue[0]);

$metadata[] = $this->serializer->encodeMessage($metadataElement);

}

}

return new $exception($ex->getMessage(), $ex->getCode(), $ex, $metadata);

}