Merge pull request #2 from adrianceding/master

增加onclose onconnect回调
walkor · Aug 9, 2017 · 23a2ccb · 23a2ccb
2 parents 644341d + f50b256
commit 23a2ccb
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/src/Client.php b/src/Client.php
@@ -15,6 +15,18 @@ class Client
      */
     public static $onMessage = null;
 
+    /**
+     * onConnect
+     * @var callback
+     */
+    public static $onConnect = null;
+
+    /**
+     * onClose
+     * @var callback
+     */
+    public static $onClose = null;
+
     /**
      * Connction to channel server.
      * @var TcpConnection
@@ -129,6 +141,9 @@ public static function onRemoteClose()
         self::$_remoteConnection = null;
         self::clearTimer();
         self::$_reconnectTimer = Timer::add(1, 'Channel\Client::connect', array(self::$_remoteIp, self::$_remotePort));
+        if (self::$onClose) {
+            call_user_func(Client::$onClose);
+        }
     }
 
     /**
@@ -143,6 +158,10 @@ public static function onRemoteConnect()
             self::subscribe($all_event_names);
         }
         self::clearTimer();
+
+        if (self::$onConnect) {
+            call_user_func(Client::$onConnect);
+        }
     }
 
     /**