carpenstar / bybitapi-sdk-websockets

src/WebSockets/Channels/Derivatives/PublicChannels/PublicTrade/Argument/PublicTradeArgument.php

Spacing +1 added lines, -1 removed lines

@@ -14,6 +14,6 @@
 
     public function getTopic(): array
     {
-        return [WebSocketTopicNameEnum::DERIVATIVES_PUBLIC_TRADE.".{$this->getSymbols()}"];
+        return [WebSocketTopicNameEnum::DERIVATIVES_PUBLIC_TRADE . ".{$this->getSymbols()}"];
     }
 }

src/WebSockets/Channels/Derivatives/PublicChannels/PublicTrade/Entities/PublicTradeResponse.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
 
         if (!empty($data['data'])) {
             if (!empty($data['data'])) {
-                array_map(function ($item) use ($collection) {
+                array_map(function($item) use ($collection) {
                     $collection->push(ResponseDtoBuilder::make(PublicTradeResponseItem::class, $item));
                 }, $data['data']);
             }

src/WebSockets/Channels/Derivatives/PublicChannels/Kline/Argument/KlineArgument.php

Spacing +1 added lines, -1 removed lines

@@ -24,6 +24,6 @@
 
     public function getTopic(): array
     {
-        return [WebSocketTopicNameEnum::DERIVATIVES_KLINE.".{$this->interval}.{$this->getSymbols()}"];
+        return [WebSocketTopicNameEnum::DERIVATIVES_KLINE . ".{$this->interval}.{$this->getSymbols()}"];
     }
 }
\ No newline at end of file

src/WebSockets/Channels/Derivatives/PublicChannels/Kline/Entity/KlineResponse.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
 
         if (!empty($data['data'])) {
             if (!empty($data['data'])) {
-                array_map(function ($item) use ($collection) {
+                array_map(function($item) use ($collection) {
                     $collection->push(ResponseDtoBuilder::make(KlineResponseItem::class, $item));
                 }, $data['data']);
             }

src/WebSockets/Channels/Derivatives/PublicChannels/Liquidation/Argument/LiquidationArgument.php

Spacing +1 added lines, -1 removed lines

@@ -16,6 +16,6 @@
 
     public function getTopic(): array
     {
-        return [WebSocketTopicNameEnum::DERIVATIVES_LIQUIDATION.".{$this->getSymbols()}"];
+        return [WebSocketTopicNameEnum::DERIVATIVES_LIQUIDATION . ".{$this->getSymbols()}"];
     }
 }

src/WebSockets/Channels/Derivatives/PublicChannels/Liquidation/Entity/LiquidationResponse.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
             
             $data['data'] = array_is_list($data['data']) ? $data['data'] : [$data['data']];
 
-            array_map(function ($item) use ($collection) {
+            array_map(function($item) use ($collection) {
                 $collection->push(ResponseDtoBuilder::make(OrderBookPriceAbstract::class, $item));
             }, $data['data']);
         }

src/WebSockets/Objects/WebSockets/WebSocketsPublicChannel.php

Spacing +3 added lines, -3 removed lines

@@ -41,18 +41,18 @@
      */
     public function execute(): void
     {
-        $this->worker->onWorkerStart = function () {
+        $this->worker->onWorkerStart = function() {
 
             $connection = new AsyncTcpConnection($this->hostStream . static::CHANNEL_TYPE . "/" . static::CHANNEL_ACCESS . "/v3");
 
             $connection->transport = 'ssl';
-            $connection->onConnect = function ($connection) {
+            $connection->onConnect = function($connection) {
                 $connection->send(json_encode(["op" => $this->operation, "args" => $this->topic]));
             };
 
             $callback = $this->callback;
 
-            $connection->onMessage = function ($connection, $message) use ($callback) {
+            $connection->onMessage = function($connection, $message) use ($callback) {
             
                 $message = json_decode($message, true);