eole-io / sandstone

    /**

     * {@InheritDoc}

     */

    public function onSubscribe(ConnectionInterface $conn, $topic)

    {

        $this->dispatch(ConnectionEvent::ON_SUBSCRIBE, new WampEvent($conn, $topic));

        $this->logger->info('Topic event', ['event' => 'subscribe', 'topic' => $topic]);

        $this->getTopic($topic)->onSubscribe($conn, $topic);

    }

    /**

     * {@InheritDoc}

    /**

     * {@InheritDoc}

     */

    public function onUnSubscribe(ConnectionInterface $conn, $topic)

    {

        $this->dispatch(ConnectionEvent::ON_UNSUBSCRIBE, new WampEvent($conn, $topic));

        $this->logger->info('Topic event', ['event' => 'unsubscribe', 'topic' => $topic]);

        $this->getTopic($topic)->onUnSubscribe($conn, $topic);

    }

    /**

     * {@InheritDoc}

    /**

     * {@InheritDoc}

     */

    public function onClose(ConnectionInterface $conn)

    {

        $this->dispatch(ConnectionEvent::ON_CLOSE, new ConnectionEvent($conn));

        $this->logger->info('Connection event', ['event' => 'close']);

        foreach ($this->topics as $topic) {

            if ($topic->has($conn)) {

                $topic->onUnSubscribe($conn, $topic);

            }

        }

    }

    /**

     * {@InheritDoc}