tidal / WampWatch

     *

     * @return PromiseAdapter

     */

    public function subscribe($topicName, callable $callback, $options = null)

    {

        $this->on($topicName, $callback);

        $futureResult = new Deferred();

        $this->subscriptions[$topicName] = $futureResult;

        $this->subscribing[$topicName] = new SubscribeMessage(

            count($this->subscriptions),

            (object) $options,

            $topicName

        );

        return $this->createPromiseAdapter(

            $futureResult->promise()

        );

    }

    /**

     * Trigger a SUBSCRIBED message for given topic.

     *

     * @return PromiseAdapter

     */

    public function register($procedureName, callable $callback, $options = null)

    {

        $this->procedures[$procedureName] = $callback;

        $futureResult = new Deferred();

        $this->registrations[$procedureName] = $futureResult;

        $this->registering[$procedureName] = new RegisterMessage(

            count($this->registering),

            $options,

            $procedureName

        );

        return $this->createPromiseAdapter(

            $futureResult->promise()

        );

    }

    /**

     * Trigger a REGISTERED message for given procedure.