add connect method

Author: JanHuang

src/Client.php

@@ -81,6 +81,11 @@ class Client
      */
     protected $callbacks = [];
 
+    /**
+     * @var bool
+     */
+    protected $async = false;
+
     /**
      * Client constructor.
      * @param $uri
@@ -111,6 +116,7 @@ public function createRequest($url, $async = false, $keep = false)
         $this->scheme = isset($info['scheme']) ? $info['scheme'] : 'http';
         $this->host = $info['host'];
         $this->port = isset($info['port']) ? $info['port'] : 80;
+        $this->async = $async;
 
         switch ($this->scheme) {
             case 'tcp':
@@ -307,6 +313,14 @@ public function onError(swoole_client $client) {}
      */
     public function onClose(swoole_client $client) {}
 
+    /**
+     * @return mixed
+     */
+    public function connect()
+    {
+        return $this->client->connect($this->host, $this->port, $this->timeout);
+    }
+
     /**
      * @return bool
      */
@@ -341,18 +355,18 @@ public function send($data = '')
             if (null === $this->client) {
                 throw new LogicException('Please call the createRequest method first');
             }
-            if ( ! $this->client->connect($this->host, $this->port, $this->timeout)) {
+            if ( ! $this->connect()) {
                 throw new RuntimeException(socket_strerror($this->client->errCode));
             }
+        }
 
-            $this->client->send($this->wrapBody($data));
-            $receive = $this->receive();
-        } else {
-            $this->client->send($this->wrapBody($data));
-            $receive = $this->receive();
+        $this->client->send($this->wrapBody($data));
+
+        if (!$this->async) {
+            return $this->receive();
         }
 
-        return $receive;
+        return true;
     }
 
     /**
@@ -363,7 +377,7 @@ public function start()
         foreach ($this->callbacks as $event => $callback) {
             $this->client->on($event, $callback);
         }
-        $this->client->connect($this->host, $this->port, $this->timeout);
+        $this->connect();
     }
 
     public function __destruct()