tidal / WampWatch

     * @param string $procedureName

     * @param int    $requestId

     */

    public function confirmUnregistration($procedureName, $requestId = 1)

    {

        if (!isset($this->unregistrations[$procedureName])) {

            throw new \RuntimeException("No registration to procedure '$procedureName' initiated.");

        }

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

        $result = new UnregisteredMessage($requestId);

        $futureResult->resolve($result);

    }

    /**

     * Call.

     * @param string    $procedureName

     * @param \stdClass $result

     */

    public function respondToCall($procedureName, $result)

    {

        if (!isset($this->calls[$procedureName])) {

            throw new \RuntimeException("No call to topic '$procedureName' initiated.");

        }

        /* @var $futureResult Deferred */

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

        $futureResult->resolve($result);

    }

    /**