Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
Exception.php	70 B	-rw-r--r--	2017-12-12 09:00
JsonException.php	904 B	-rw-r--r--	2017-12-12 09:00
ServerProtocol.php	4.65 KB	-rw-r--r--	2017-12-12 09:00
Topic.php	2.32 KB	-rw-r--r--	2017-12-12 09:00
TopicManager.php	3.02 KB	-rw-r--r--	2017-12-12 09:00
WampConnection.php	3.42 KB	-rw-r--r--	2017-12-12 09:00
WampServer.php	1.81 KB	-rw-r--r--	2017-12-12 09:00
WampServerInterface.php	1.92 KB	-rw-r--r--	2017-12-12 09:00

Rename

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

/**
 * A topic/channel containing connections that have subscribed to it
 */
class Topic implements \IteratorAggregate, \Countable {
    private $id;

private $subscribers;

/**
     * @param string $topicId Unique ID for this object
     */
    public function __construct($topicId) {
        $this->id = $topicId;
        $this->subscribers = new \SplObjectStorage;
    }

/**
     * @return string
     */
    public function getId() {
        return $this->id;
    }

public function __toString() {
        return $this->getId();
    }

/**
     * Send a message to all the connections in this topic
     * @param string|array $msg Payload to publish
     * @param array $exclude A list of session IDs the message should be excluded from (blacklist)
     * @param array $eligible A list of session Ids the message should be send to (whitelist)
     * @return Topic The same Topic object to chain
     */
    public function broadcast($msg, array $exclude = array(), array $eligible = array()) {
        $useEligible = (bool)count($eligible);
        foreach ($this->subscribers as $client) {
            if (in_array($client->WAMP->sessionId, $exclude)) {
                continue;
            }

if ($useEligible && !in_array($client->WAMP->sessionId, $eligible)) {
                continue;
            }

$client->event($this->id, $msg);
        }

return $this;
    }

/**
     * @param  WampConnection $conn
     * @return boolean
     */
    public function has(ConnectionInterface $conn) {
        return $this->subscribers->contains($conn);
    }

/**
     * @param WampConnection $conn
     * @return Topic
     */
    public function add(ConnectionInterface $conn) {
        $this->subscribers->attach($conn);

return $this;
    }

/**
     * @param WampConnection $conn
     * @return Topic
     */
    public function remove(ConnectionInterface $conn) {
        if ($this->subscribers->contains($conn)) {
            $this->subscribers->detach($conn);
        }

return $this;
    }

/**
     * {@inheritdoc}
     */
    public function getIterator() {
        return $this->subscribers;
    }

/**
     * {@inheritdoc}
     */
    public function count() {
        return $this->subscribers->count();
    }
}