rx/websocket

Websockets for PHP using Rx

2.1.7 2022-03-05 05:31 UTC

Requires

• ratchet/rfc6455: ^0.3
• react/http: ^1
• reactivex/rxphp: ^2.0.1
• voryx/event-loop: ^3.0 || ^2.0.2

Requires (Dev)

• phpunit/phpunit: ^9

MIT

• Matt Bonneau
• David Dan

• websocket
• WebSockets
• react
• reactive
• rx
• rfc6455
• rx.php
• rxphp

README

Rx\Websocket is a PHP Websocket library.

Usage

Client

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

$client->subscribe(
    function (\Rx\Websocket\MessageSubject $ms) {
        $ms->subscribe(
            function ($message) {
                echo $message . "\n";
            }
        );

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

        $sayHello();
        \EventLoop\addPeriodicTimer(5, $sayHello);
    },
    function ($error) {
        // connection errors here
    },
    function () {
        // stopped trying to connect here
    }
);

An Echo Server

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

$server->subscribe(function (\Rx\Websocket\MessageSubject $cs) {
    $cs->subscribe($cs);
});

Server that dumps everything to the console

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

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

Installation

Using composer:

composer require rx/websocket