Ratchet w/ php-uv

UvConnection.php

<?php
namespace Ratchet\Server;
use Ratchet\ConnectionInterface;

class UvConnection implements ConnectionInterface {
    private $client;

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

    public function send($data) {
        uv_write($this->client, $data, function($sock, $stat) {});
    }

    public function close() {
        uv_close($this->client);
    }
}

UvServer.php

<?php
namespace Ratchet\Server;
use Ratchet\MessageComponentInterface;

class IoLibUvServer {
    protected $app;

    protected $tcp;

    public function __construct(MessageComponentInterface $app, $port = 80, $address = '0.0.0.0') {
        gc_enable();
        set_time_limit(0);
        ob_implicit_flush();

        $this->app = $app;
        $this->tcp = uv_tcp_init();

        uv_tcp_bind($this->tcp, uv_ip4_addr($address, $port));
    }

    public function run() {
        $app = $this->app;

        uv_listen($this->tcp, 100, function($server) use ($app) {
            $client = uv_tcp_init();
            uv_accept($server, $client);

            $conn = new UvConnection($client);
            $app->onOpen($conn);

            uv_read_start($client, function($socket, $nread, $buffer) use ($server, $app, $conn) {
                $app->onMessage($conn, $buffer);
            });
        });

        uv_run();
    }
}