modify result

src/Service.php

@@ -101,9 +101,9 @@ public function call(string $func, array $params)
             }
 
             App::profileStart($profileKey);
-            $result = $client->recv();
+            $result = $client->receive();
             App::profileEnd($profileKey);
-            $connectPool->release($client);
+            $client->release(true);
 
             App::debug(sprintf('%s call %s success, data=%', $this->interface, $func, json_encode($data, JSON_UNESCAPED_UNICODE)));
             $result = $packer->unpack($result);
@@ -170,7 +170,6 @@ private function deferCall(string $func, array $params)
 
             $result = $circuitBreaker->call([$connection, 'send'], [$packData], $fallback);
 
-            // 错误处理
             if ($result === null || $result === false) {
                 return null;
             }
@@ -196,13 +195,13 @@ private function deferCall(string $func, array $params)
     private function getResult(ConnectionInterface $connection = null, string $profileKey = '', $result = null)
     {
         if (App::isCoContext()) {
-            $serviceCoResult = new ServiceCoResult($connection, $profileKey);
+            $serviceCoResult = new ServiceCoResult($result, $connection, $profileKey);
             $serviceCoResult->setFallbackData($result);
 
             return $serviceCoResult;
         }
 
-        return new ServiceDataResult($result, $connection);
+        return new ServiceDataResult($result, $connection, $profileKey);
     }
 
     /**

src/Service/ServiceCoResult.php

@@ -3,12 +3,12 @@
 namespace Swoft\Rpc\Client\Service;
 
 use Swoft\App;
-use Swoft\Core\AbstractCoResult;
+use Swoft\Core\AbstractResult;
 
 /**
- * The cor result of server
+ * ServiceCoResult
  */
-class ServiceCoResult extends AbstractCoResult
+class ServiceCoResult extends AbstractResult
 {
     /**
      * @var mixed

src/Service/ServiceConnection.php

@@ -36,7 +36,7 @@ public function createConnection()
 
     public function receive()
     {
-        $result = $this->connection->recv();
+        $result = $this->recv();
         $this->recv = true;
         return $result;
     }

src/Service/ServiceDataResult.php

@@ -3,12 +3,12 @@
 namespace Swoft\Rpc\Client\Service;
 
 use Swoft\App;
-use Swoft\Core\AbstractDataResult;
+use Swoft\Core\AbstractResult;
 
 /**
  * The data result of service
  */
-class ServiceDataResult extends AbstractDataResult
+class ServiceDataResult extends AbstractResult
 {
     /**
      * @var mixed

src/Service/SyncServiceConnection.php

@@ -54,14 +54,26 @@ public function check(): bool
         return true;
     }
 
+    /**
+     * @return string
+     */
+    public function receive()
+    {
+        $result = $this->recv();
+        $this->recv = true;
+        return $result;
+    }
+
     /**
      * @param string $data
      *
      * @return bool
      */
     public function send(string $data): bool
     {
-        return fwrite($this->connection, $data);
+        $result = fwrite($this->connection, $data);
+        $this->recv = false;
+        return $result;
     }
 
     /**