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

[WAMP][BCB] Property name change

Browse Source 
Changed $conn->WAMP->topics to
$conn->WAMP->subscriptions
This commit is contained in:
Chris Boden 2012-07-22 17:55:53 -04:00
parent 226ec07b02
commit 6ee81074d3
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Ratchet/Wamp/TopicManager.php
View File

@ -22,7 +22,7 @@ class TopicManager implements WsServerInterface, WampServerInterface {
* {@inheritdoc} * {@inheritdoc}
*/ */
public function onOpen(ConnectionInterface $conn) { public function onOpen(ConnectionInterface $conn) {
$conn->WAMP->topics = new \SplObjectStorage; $conn->WAMP->subscriptions = new \SplObjectStorage;
$this->app->onOpen($conn); $this->app->onOpen($conn);
} }
@ -39,12 +39,12 @@ class TopicManager implements WsServerInterface, WampServerInterface {
public function onSubscribe(ConnectionInterface $conn, $topic) { public function onSubscribe(ConnectionInterface $conn, $topic) {
$topicObj = $this->getTopic($topic); $topicObj = $this->getTopic($topic);
if ($conn->WAMP->topics->contains($topicObj)) { if ($conn->WAMP->subscriptions->contains($topicObj)) {
return; return;
} }
$this->topicLookup[$topic]->add($conn); $this->topicLookup[$topic]->add($conn);
$conn->WAMP->topics->attach($topicObj); $conn->WAMP->subscriptions->attach($topicObj);
$this->app->onSubscribe($conn, $topicObj); $this->app->onSubscribe($conn, $topicObj);
} }
@ -54,8 +54,8 @@ class TopicManager implements WsServerInterface, WampServerInterface {
public function onUnsubscribe(ConnectionInterface $conn, $topic) { public function onUnsubscribe(ConnectionInterface $conn, $topic) {
$topicObj = $this->getTopic($topic); $topicObj = $this->getTopic($topic);
if ($conn->WAMP->topics->contains($topicObj)) { if ($conn->WAMP->subscriptions->contains($topicObj)) {
$conn->WAMP->topics->detach($topicObj); $conn->WAMP->subscriptions->detach($topicObj);
} else { } else {
return; return;
} }

4
tests/Ratchet/Tests/Wamp/TopicManagerTest.php
View File

@ -89,7 +89,7 @@ class TopicManagerTest extends \PHPUnit_Framework_TestCase {
$this->mngr->onSubscribe($this->conn, $name); $this->mngr->onSubscribe($this->conn, $name);
$this->assertTrue($this->conn->WAMP->topics->contains($topic)); $this->assertTrue($this->conn->WAMP->subscriptions->contains($topic));
} }
public function testDoubleSubscriptionFiresOnce() { public function testDoubleSubscriptionFiresOnce() {
@ -130,7 +130,7 @@ class TopicManagerTest extends \PHPUnit_Framework_TestCase {
$this->mngr->onSubscribe($this->conn, $name); $this->mngr->onSubscribe($this->conn, $name);
$this->mngr->onUnsubscribe($this->conn, $name); $this->mngr->onUnsubscribe($this->conn, $name);
$this->assertFalse($this->conn->WAMP->topics->contains($topic)); $this->assertFalse($this->conn->WAMP->subscriptions->contains($topic));
} }
public function testOnPublishBubbles() { public function testOnPublishBubbles() {