phpのratchet/pawlを使ってwebsocket clientを作る

とあるAPIサービスのクライアントサンプルがtextalk/websocketで書かれていたのですが、
なんかメモリリーク起こしているようで、立ち上げっぱなしにしてると落ちるため、
ratchet/pawlを使って書き直しました。

composerでratchet/pawlをインストール

composer require ratchet/pawl

コード

client.php

<?php

require __DIR__ . '/vendor/autoload.php';

/**
 * 接続
 */
function connectServer($connector, $loop) {
    // 接続先情報（適宜変更）
    $url = "ws://localhost:8080";
    $connector($url)->then(function(Ratchet\Client\WebSocket $conn) use ($connector, $loop) {
        // メッセージ受信イベント
        $conn->on("message", function(\Ratchet\RFC6455\Messaging\MessageInterface $msg) {
            // メッセージ受け取ったときの処理（適宜変更）
            print_r($msg);
        });

        // 切断イベント
        $conn->on("close", function($code = null, $reason = null) use ($connector, $loop) {
            $loop->addTimer(1, function() use ($connector, $loop) {
                // 切断されたら自動で再接続させる
                connectServer($connector, $loop);
            });
        });

        // 接続できたらテストでサーバへメッセージ送ってみる （適宜変更）
        sendMessage($conn, "hello world.");
    }, function (\Exception $e) use ($loop) {
        // 例外処理（処理停止）
        $loop->stop();
    });
}


/**
 * メッセージ送信
 */
function sendMessage($conn, $msg) {
    $conn->send($msg);
}


/**
 * 本体
 */
$loop = React\EventLoop\Factory::create();
$connector = new Ratchet\Client\Connector($loop);
connectServer($connector, $loop);
$loop->run();