Skip to content

Commit 4c5b4d4

Browse files
committed
fix
1 parent dfa551b commit 4c5b4d4

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

src/Protocols/Websocket.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,8 +84,8 @@ class Websocket
8484
*/
8585
public static function input(string $buffer, TcpConnection $connection): int
8686
{
87-
$connection->websocketOrigin = $connection->websocketOrigin ?? null;
88-
$connection->websocketClientProtocol = $connection->websocketClientProtocol ?? null;
87+
$connection->websocketOrigin = $connection?->websocketOrigin;
88+
$connection->websocketClientProtocol = $connection?->websocketClientProtocol;
8989
// Receive length.
9090
$recvLen = strlen($buffer);
9191
// We need more data.

src/Protocols/Ws.php

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -239,6 +239,8 @@ public static function encode(string $payload, AsyncTcpConnection $connection):
239239
if (empty($connection->websocketType)) {
240240
$connection->websocketType = self::BINARY_TYPE_BLOB;
241241
}
242+
$connection->websocketOrigin = $connection->websocketOrigin ?? null;
243+
$connection->websocketClientProtocol = $connection->websocketClientProtocol ?? null;
242244
if (empty($connection->context->handshakeStep)) {
243245
static::sendHandshake($connection);
244246
}
@@ -323,8 +325,8 @@ public static function decode(string $bytes, AsyncTcpConnection $connection): st
323325
*/
324326
public static function onConnect(AsyncTcpConnection $connection): void
325327
{
326-
$connection->websocketOrigin = $connection->websocketOrigin ?? null;
327-
$connection->websocketClientProtocol = $connection->websocketClientProtocol ?? null;
328+
$connection->websocketOrigin = $connection?->websocketOrigin;
329+
$connection->websocketClientProtocol = $connection?->websocketClientProtocol;
328330
static::sendHandshake($connection);
329331
}
330332

0 commit comments

Comments
 (0)