check for frame

src/WebSockets/WsConnection.php

@@ -97,9 +97,11 @@ public function onClose(callable $callback): void
     /**
      * Close the connection.
      */
-    public function close(FrameInterface $frame): void
+    public function close(FrameInterface $frame = null): void
     {
-        $this->send($frame);
+        if ($frame) {
+            $this->send($frame);
+        }
 
         $this->connection->close();
     }

tests/Feature/Reverb/ServerTest.php

@@ -315,13 +315,6 @@
     $this->connect();
 });
 
-it('can receive a pong control frame', function () {
-    $frame = new Frame('ping', true, Frame::OP_PING);
-    $response = $this->sendRaw($frame);
-
-    expect($response)->toBe('pong');
-});
-
 it('clears application state between requests', function () {
     $this->subscribe('test-channel');
 

tests/ReverbTestCase.php

@@ -182,24 +182,6 @@ public function send(array $message, WebSocket $connection = null): string
         return await($promise->promise());
     }
 
-    /**
-     * Send a message to the connected client.
-     */
-    public function sendRaw(mixed $message, WebSocket $connection = null): string
-    {
-        $promise = new Deferred;
-
-        $connection = $connection ?: $this->connect();
-
-        $connection->on('message', function ($message) use ($promise) {
-            $promise->resolve((string) $message);
-        });
-
-        $connection->send($message);
-
-        return await($promise->promise());
-    }
-
     /**
      * Disconnect the connected client.
      */

tests/Specification/spec-server.php

@@ -31,7 +31,6 @@ function routes()
         Route::get('/', function (RequestInterface $request, WsConnection $connection) {
             $connection->onMessage(function ($message) use ($connection) {
                 $connection->send($message);
-                $connection->send($message);
             });
             $connection->openBuffer();
         })