diff --git a/src/ChromeDevtoolsProtocol/WebSocket/WebSocketClient.php b/src/ChromeDevtoolsProtocol/WebSocket/WebSocketClient.php index 79cfbf19..fb2050b9 100644 --- a/src/ChromeDevtoolsProtocol/WebSocket/WebSocketClient.php +++ b/src/ChromeDevtoolsProtocol/WebSocket/WebSocketClient.php @@ -28,4 +28,16 @@ public function setDeadline(?\DateTimeImmutable $deadline) $this->socket->setDeadline($deadline); } + public function receive() + { + // Forward the receive() call to Client::receive() + $payloads = parent::receive(); + + // If the latest payload(s) are received, clear the buffer. We don't need that copy any more. + if ($payloads) + $this->received = array(); + + // Return the latest received payloads + return $payloads; + } }