as2252258/kiri-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 8 Wiki Activity

1

Browse Source
This commit is contained in:
Administrator
2021-12-11 16:48:36 +08:00
parent 4b7ebb2572
commit 6098045ab3
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/AsyncClient.php
+13 -4
View File
@@ -61,9 +61,9 @@ class AsyncClient extends ClientAbstracts
if ($this->client->statusCode < 0) {
throw new Exception($this->client->errMsg);
}
$this->setStatusCode($this->client->getStatusCode());
$this->setBody($this->client->getBody());
$this->setResponseHeader($this->client->headers);
// $this->setStatusCode($this->client->getStatusCode());
// $this->setBody($this->client->getBody());
// $this->setResponseHeader($this->client->headers);
} catch (\Throwable $exception) {
Kiri::getDi()->get(Logger::class)->error('rpc', [$exception]);
$this->setStatusCode(-1);
@@ -114,8 +114,17 @@ class AsyncClient extends ClientAbstracts
[$header, $body] = explode("\r\n\r\n", $revice);
var_dump($revice);
$header = explode("\r\n", $header);
$status = array_shift($header);
[$path, $status, $pro] = explode(' ', $status);
$this->setBody($body);
$this->setResponseHeader(explode("\r\n", $header));
$this->setStatusCode(intval($status));
$this->setResponseHeader($header);
//
// $this->client->setHeaders($this->getHeader());