*/ class ReactSocketPuller extends WebsocketPuller { protected $msgBus; protected $server; public function __construct(LoopInterface $loop, MessageBus $msgBus) { $this->msgBus = $msgBus; $this->server = new Server($loop); $this->server->on("connection", array($this, 'onConnection')); } public function onConnection(ConnectionInterface $conn) { $conn->on("data", function($data){ $this->msgBus->onNotify($data); }); } public function listen($ip, $port) { $this->server->listen($port, $ip); } } WebSVN - freenet-router - Blame - Rev 2 - /trunk/freenet-router/var/www/freenet-router/Framework/Libraries/MessageBus/ReactSocketPuller.php

freenet-router

Subversion Repositories:

[/] [trunk/] [freenet-router/] [var/] [www/] [freenet-router/] [Framework/] [Libraries/] [MessageBus/] [ReactSocketPuller.php] - Blame information for rev 2

Line No.	Rev	Author	Line