faeez/mxmbsocket
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Repo. Project Releases Wiki Activity

Merge branch 'socket' into 0.4

Browse Source
This commit is contained in:
Chris Boden 2017-03-10 09:19:04 -05:00
commit 8d8d574199
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/Ratchet/Server/IoServer.php
View File

@ -24,6 +24,7 @@ class IoServer {
/**
* Array of React event handlers
* @var \SplFixedArray
* @deprecated exists BC only, now unused
*/
protected $handlers;
@ -53,9 +54,6 @@ class IoServer {
$socket->on('connection', array($this, 'handleConnect'));
$this->handlers = new \SplFixedArray(3);
$this->handlers[0] = array($this, 'handleData');
$this->handlers[1] = array($this, 'handleEnd');
$this->handlers[2] = array($this, 'handleError');
}
/**
@ -100,9 +98,16 @@ class IoServer {
$this->app->onOpen($conn->decor);
$conn->on('data', $this->handlers[0]);
$conn->on('end', $this->handlers[1]);
$conn->on('error', $this->handlers[2]);
$that = $this;
$conn->on('data', function ($data) use ($conn) {
$that->handleData($data, $conn);
});
$conn->on('close', function () use ($conn, $that) {
$that->handleEnd($conn);
});
$conn->on('error', function (\Exception $e) use ($conn, $that) {
$that->handleError($e, $conn);
});
}
/**