bootstrap.php

<?php

$loop   = React\EventLoop\Factory::create();
$pusher = new Seedstream\Pusher($loop);

$webSock = new React\Socket\Server($loop);
$webSock->listen(8080, '0.0.0.0');
$webServer = new Ratchet\Server\IoServer(
    new Ratchet\WebSocket\WsServer(
        new Ratchet\Wamp\WampServer(
            $pusher
        )
    ),
    $webSock
);

$loop->run();

Pusher.php

<?php

namespace Seedstream;

use React\EventLoop\LoopInterface,
    React\Socket\ConnectionInterface;

class Pusher
{
    private $loop;

    public function __construct(LoopInterface $loop)
    {
        $this->loop = $loop;
    }

    public function onSubscribe(ConnectionInterface $conn, $subscription) 
    {
        list($subject, $userId, $token) = explode(':', $subscription->getId());

        $this->loop->addPeriodicTimer(4, function() use ($conn, $subscription, $subject, $userId) {
            $subscription->broadcast(['userId' => $userId, 'subject' => $subject, 'resourceId' => $conn->resourceId]);
        });

        echo sprintf("Client Connected: %s, userId: %d, subject: %s" . PHP_EOL, $conn->remoteAddress, $userId, $subject);
    }
}