tidal / WampWatch

     *

     * @return PromiseAdapter

     */

    public function publish($topicName, $arguments = null, $argumentsKw = null, $options = null)

    {

        $this->publications[$topicName] = static::createDeferredAdapter();

        $this->publishing[$topicName] = new PublishMessage(

            count($this->publishing),

            $options,

            $topicName,

            $arguments,

            $argumentsKw

        );

        return $this->publications[$topicName]->promise();

    }

    /**

     * Trigger a PUBLISHED message for given topic.

     *

     * @return PromiseAdapter

     */

    public function call($procedureName, $arguments = null, $argumentsKw = null, $options = null)

    {

        $this->calls[$procedureName] = static::createDeferredAdapter();

        $this->calling[$procedureName] = new CallMessage(

            count($this->calling),

            $options,

            $procedureName,

            $arguments,

            $argumentsKw

        );

        return $this->calls[$procedureName]->promise();

    }

    /**

     * Process ResultMessage.