rx/websocket

Websockets for PHP using Rx

Maintainers

Details

github.com/RxPHP/RxWebsocket

Source

Issues

Installs: 91 818

Dependents: 5

Suggesters: 0

Security: 0

Stars: 32

Watchers: 5

Forks: 6

Open Issues: 4

2.1.6 2021-10-31 16:22 UTC

Requires

Requires (Dev)

MIT dba6a0aa93ebafeb5a70d23ef9ec7ad4f002fa5b

  • Matt Bonneau <matt.woop@bonneau.net>
  • David Dan <davidwdan.woop@gmail.com>

websocketWebSocketsreactreactiverxrfc6455rx.phprxphp

This package is not auto-updated.

Last update: 2022-01-09 17:20:06 UTC

README

CI status

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