carpenstar / bybitapi-sdk-core

src/Core/Objects/WebSockets/WebSocketsPublicChannel.php

Spacing +5 added lines, -5 removed lines

@@ -43,9 +43,9 @@ 
      */
     public function execute(): void
     {
-        $this->worker->onWorkerStart = function () {
+        $this->worker->onWorkerStart = function() {
 
-            $connection = new AsyncTcpConnection($this->hostStream.'/'.self::CHANNEL_ACCESS.'/'.$this->streamType);
+            $connection = new AsyncTcpConnection($this->hostStream . '/' . self::CHANNEL_ACCESS . '/' . $this->streamType);
             $connection->transport = 'ssl';
 
             $heartbeatTimerId = Timer::add(20, function() use ($connection) {
@@ -58,7 +58,7 @@ 
              * @param $connection
              * @return void
              */
-            $connection->onConnect = function ($connection) use (&$heartbeatTimerId) {
+            $connection->onConnect = function($connection) use (&$heartbeatTimerId) {
                 $connection->send(json_encode(["op" => $this->operation, "args" => $this->topic]));
             };
 
@@ -72,7 +72,7 @@ 
              * @return void
              * @throws \Exception
              */
-            $connection->onMessage = function ($connection, $message) use ($callback) {
+            $connection->onMessage = function($connection, $message) use ($callback) {
                 $message = json_decode($message, true);
                 $responseDto = $this->getResponseClassname($this->streamType);
 
@@ -102,7 +102,7 @@ 
              * @param $connection
              * @return void
              */
-            $this->worker->onClose = function ($connection) use (&$heartbeatTimerId) {
+            $this->worker->onClose = function($connection) use (&$heartbeatTimerId) {
                 Timer::del($heartbeatTimerId);
             };