subscribe channel without loop restart

Author: Dave Xie

README.md

@@ -126,8 +126,11 @@ $channels = [
 $api->subscribePublicChannels($query, $channels, function (array $message, WebSocket $ws, LoopInterface $loop) use ($api) {
     var_dump($message);
 
+    // Subscribe another channel
+    // $ws->send(json_encode($api->createSubscribeMessage('/contractMarket/ticker:ETHUSDTM')));
+
     // Unsubscribe the channel
-    // $ws->send(json_encode($api->createUnsubscribeMessage('/market/ticker:ETH-BTC')));
+    // $ws->send(json_encode($api->createUnsubscribeMessage('/contractMarket/ticker:XBTUSDM')));
 
     // Stop loop
     // $loop->stop();

examples/WebSocketFeed.php

@@ -32,8 +32,11 @@
 $api->subscribePublicChannels($query, $channels, function (array $message, WebSocket $ws, LoopInterface $loop) use ($api) {
     var_dump($message);
 
+    // Subscribe another channel
+    // $ws->send(json_encode($api->createSubscribeMessage('/contractMarket/ticker:ETHUSDTM')));
+
     // Unsubscribe the channel
-    // $ws->send(json_encode($api->createUnsubscribeMessage('/market/ticker:ETH-BTC')));
+    // $ws->send(json_encode($api->createUnsubscribeMessage('/contractMarket/ticker:XBTUSDM')));
 
     // Stop loop
     // $loop->stop();

src/Api.php

@@ -16,12 +16,12 @@ abstract class Api
     /**
      * @var string SDK Version
      */
-    const VERSION = '1.0.19';
+    const VERSION = '1.0.20';
 
     /**
      * @var string SDK update date
      */
-    const UPDATE_DATE = '2022.02.27';
+    const UPDATE_DATE = '2022.03.25';
 
     /**
      * @var string

src/PrivateApi/WebSocketFeed.php

@@ -287,7 +287,7 @@ public function subscribePrivateChannel(array $query, array $channel, callable $
     }
 
     /**
-     * Create message for ping
+     * Create a ping message
      * @param string $id
      * @return array
      */
@@ -297,7 +297,20 @@ public function createPingMessage($id = null)
     }
 
     /**
-     * Create message for unsubscribe
+     * Create a subscription message
+     * @param string $topic
+     * @param bool $privateChannel
+     * @param bool $response
+     * @param string $id
+     * @return array
+     */
+    public function createSubscribeMessage($topic, $privateChannel = false, $response = true, $id = null)
+    {
+        return ['id' => $id ?: uniqid('', true), 'type' => 'subscribe', 'topic' => $topic, 'privateChannel' => $privateChannel, 'response' => $response];
+    }
+
+    /**
+     * Create an unsubscribe message
      * @param string $topic
      * @param bool $privateChannel
      * @param bool $response