rx / websocket
Websockets for PHP using Rx
Installs: 86 871
Dependents: 5
Suggesters: 0
Security: 0
Stars: 30
Watchers: 4
Forks: 6
Open Issues: 5
Requires
- ratchet/rfc6455: ^0.2.2
- react/http: ^0.7.3 | ^0.8
- react/http-client: ^0.5.3
- reactivex/rxphp: ^2.0.1
- voryx/event-loop: ^3.0 || ^2.0.2
Requires (Dev)
- phpunit/phpunit: ~5.7.0
This package is not auto-updated.
Last update: 2021-04-02 23:35:52 UTC
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