rsocket-server.php

<?php
/** @noinspection PhpUnusedParameterInspection */

require 'vendor/autoload.php';

use React\EventLoop\Loop;
use RSocket\AbstractRSocket;
use RSocket\CallableSocketAcceptor;
use RSocket\Payload;
use RSocket\RSocketServer;
use Rx\Observable;
use Rx\Scheduler;


/** @noinspection PhpUnhandledExceptionInspection */
Scheduler::setDefaultFactory(static function () {
    return new Scheduler\EventLoopScheduler(Loop::get());
});

$listenUrl = "tcp://127.0.0.1:42252";
$socketAcceptor = CallableSocketAcceptor::handle(static function ($setupPayload, $sendingRSocket) {
    return AbstractRSocket::requestResponseHandler(static function ($payload) {
        print('Received:' . $payload->getDataUtf8() . PHP_EOL);
        return Observable::of(Payload::fromText("metadata", "PONG"));
    });
});
$server = RSocketServer::create($socketAcceptor)->bind($listenUrl);
echo "RSocket Server started on ${listenUrl}\n";
Loop::get()->run();