Skip to content

Commit e2fbdae

Browse files
committed
fix(Websocket): Fix problems in continuous delivery
1 parent 694f4f6 commit e2fbdae

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/Apis/Api.php

+7-1
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,13 @@ public function webSocketRes($message)
119119
if (is_array($message[0] ?? 'e')) {
120120
$messages = $message;
121121
foreach ($messages as $v) {
122-
$this->wsClient->sendData(gzencode(json_encode(array_shift($messages))), Protocol::TYPE_BINARY);
122+
try {
123+
$this->wsClient->sendData(gzencode(json_encode(array_shift($message))), Protocol::TYPE_BINARY);
124+
} catch (\Throwable $e) {
125+
dump($e->getMessage());
126+
$this->wsClient->disconnect();
127+
$this->wsClient->connect();
128+
}
123129
}
124130
} else {
125131
$this->wsClient->sendData(gzencode(json_encode($message)), Protocol::TYPE_BINARY);

0 commit comments

Comments
 (0)