delete auto_close

Author: tw2066

src/Transport/CurlerRolling.php

@@ -239,21 +239,16 @@ public function getRunningRequests()
 
     /**
      * @param CurlerRequest $request
-     * @param bool $auto_close
      * @return mixed
      * @throws TransportException
      */
-    public function execOne(CurlerRequest $request, $auto_close = false)
+    public function execOne(CurlerRequest $request)
     {
         $h = $request->handle();
         curl_exec($h);
 
         $request->setResponse($this->makeResponse($h));
 
-        if ($auto_close) {
-            $request->close();
-        }
-
         return $request->response()->http_code();
     }
 

src/Transport/Http.php

@@ -756,18 +756,16 @@ private function streaming(Stream $streamRW, CurlerRequest $request): Statement
 
             $request->header('Transfer-Encoding', 'chunked');
 
-
             if ($streamRW->isWrite()) {
                 $request->setReadFunction($callable);
             } else {
                 $request->setWriteFunction($callable);
 
-
 //                $request->setHeaderFunction($callableHead);
             }
 
 
-            $this->_curler->execOne($request, true);
+            $this->_curler->execOne($request);
             $response = new Statement($request);
             if ($response->isError()) {
                 $response->error();
@@ -818,7 +816,6 @@ public function __destruct()
         }
     }
 
-
     public function setHandle()
     {
         $this->handle = curl_init();

src/Transport/StreamInsert.php

@@ -61,7 +61,7 @@ public function insert($callback)
             //
             $this->request->header('Transfer-Encoding', 'chunked');
             $this->request->setReadFunction($callback);
-            $this->curlerRolling->execOne($this->request, true);
+            $this->curlerRolling->execOne($this->request);
             $statement = new Statement($this->request);
             $statement->error();
             return $statement;