rxphp / rxwebsocket Goto Github PK

$server = new Rx\Websocket\Server('127.0.0.1:8020');

$server->subscribe(
    function (Rx\Websocket\MessageSubject $subject) {
        $subject->subscribe(
            function ($message) {
                echo $message . PHP_EOL;
            }
        );

        $sayHello = function () use ($subject) {
            $subject->onNext('Hello');
        };

        $sayHello();

        \EventLoop\addPeriodicTimer(5, $sayHello);
    },
    function ($error) {
        echo "Connection Error";
    },
    function () {
        echo "Completed";
    }
);

$client = new \Rx\Websocket\Client('ws://127.0.0.1:9090/ws');

$client->subscribe(function (MessageSubject $ms) {
    $disp = $ms->subscribe();

    addTimer(2, function () use ($disp) {
        echo "Dispose...\n";
        $disp->dispose();
    });
});