@@ -413,7 +413,7 @@ |
||
| 413 | 413 | private function setNextFundingTime(?string $nextFundingTime): self |
| 414 | 414 | { |
| 415 | 415 | if (!empty($nextFundingTime)) { |
| 416 | - $this->nextFundingTime = DateTimeHelper::makeFromTimestamp($nextFundingTime); |
|
| 416 | + $this->nextFundingTime = DateTimeHelper::makeFromTimestamp($nextFundingTime); |
|
| 417 | 417 | } |
| 418 | 418 | return $this; |
| 419 | 419 | } |
@@ -16,6 +16,6 @@ |
||
| 16 | 16 | |
| 17 | 17 | public function getTopic(): array |
| 18 | 18 | { |
| 19 | - return [WebSocketTopicNameEnum::DERIVATIVES_LIQUIDATION.".{$this->getSymbols()}"]; |
|
| 19 | + return [WebSocketTopicNameEnum::DERIVATIVES_LIQUIDATION . ".{$this->getSymbols()}"]; |
|
| 20 | 20 | } |
| 21 | 21 | } |
@@ -26,7 +26,7 @@ |
||
| 26 | 26 | |
| 27 | 27 | $data['data'] = array_is_list($data['data']) ? $data['data'] : [$data['data']]; |
| 28 | 28 | |
| 29 | - array_map(function ($item) use ($collection) { |
|
| 29 | + array_map(function($item) use ($collection) { |
|
| 30 | 30 | $collection->push(ResponseDtoBuilder::make(OrderBookPriceAbstract::class, $item)); |
| 31 | 31 | }, $data['data']); |
| 32 | 32 | } |
@@ -41,18 +41,18 @@ |
||
| 41 | 41 | */ |
| 42 | 42 | public function execute(): void |
| 43 | 43 | { |
| 44 | - $this->worker->onWorkerStart = function () { |
|
| 44 | + $this->worker->onWorkerStart = function() { |
|
| 45 | 45 | |
| 46 | 46 | $connection = new AsyncTcpConnection($this->hostStream . static::CHANNEL_TYPE . "/" . static::CHANNEL_ACCESS . "/v3"); |
| 47 | 47 | |
| 48 | 48 | $connection->transport = 'ssl'; |
| 49 | - $connection->onConnect = function ($connection) { |
|
| 49 | + $connection->onConnect = function($connection) { |
|
| 50 | 50 | $connection->send(json_encode(["op" => $this->operation, "args" => $this->topic])); |
| 51 | 51 | }; |
| 52 | 52 | |
| 53 | 53 | $callback = $this->callback; |
| 54 | 54 | |
| 55 | - $connection->onMessage = function ($connection, $message) use ($callback) { |
|
| 55 | + $connection->onMessage = function($connection, $message) use ($callback) { |
|
| 56 | 56 | |
| 57 | 57 | $message = json_decode($message, true); |
| 58 | 58 | |
@@ -43,7 +43,7 @@ |
||
| 43 | 43 | |
| 44 | 44 | $data['data'] = isset($data['data'][0]) ? $data['data'] : [$data['data']]; |
| 45 | 45 | |
| 46 | - array_map(function ($item) use ($collection) { |
|
| 46 | + array_map(function($item) use ($collection) { |
|
| 47 | 47 | $collection->push(ResponseDtoBuilder::make(BoocktickerResponseItem::class, $item)); |
| 48 | 48 | }, $data['data']); |
| 49 | 49 | } |
@@ -39,7 +39,7 @@ |
||
| 39 | 39 | |
| 40 | 40 | if (!empty($data['data'])) { |
| 41 | 41 | $data['data'] = isset($data['data'][0]) ? $data['data'] : [$data['data']]; |
| 42 | - array_map(function ($item) use ($collection) { |
|
| 42 | + array_map(function($item) use ($collection) { |
|
| 43 | 43 | $collection->push(ResponseDtoBuilder::make(PublicTradeResponseItem::class, $item)); |
| 44 | 44 | }, $data['data']); |
| 45 | 45 | } |
@@ -42,7 +42,7 @@ |
||
| 42 | 42 | |
| 43 | 43 | $data['data'] = isset($data['data'][0]) ? $data['data'] : [$data['data']]; |
| 44 | 44 | |
| 45 | - array_map(function ($item) use ($collection) { |
|
| 45 | + array_map(function($item) use ($collection) { |
|
| 46 | 46 | $collection->push(ResponseDtoBuilder::make(KlineResponseItem::class, $item)); |
| 47 | 47 | }, $data['data']); |
| 48 | 48 | } |
@@ -39,7 +39,7 @@ |
||
| 39 | 39 | |
| 40 | 40 | if (!empty($data['data'])) { |
| 41 | 41 | $data['data'] = isset($data['data'][0]) ? $data['data'] : [$data['data']]; |
| 42 | - array_map(function ($item) use ($collection) { |
|
| 42 | + array_map(function($item) use ($collection) { |
|
| 43 | 43 | $collection->push(ResponseDtoBuilder::make(TickersResponseItem::class, $item)); |
| 44 | 44 | }, $data['data']); |
| 45 | 45 | } |