spiral / components

    /**

     * {@inheritdoc}

     */

    public function allocateStream(BucketInterface $bucket, $name)

    {

        try {

            $response = $this->client->send($this->buildRequest('GET', $bucket, $name));

        } catch (ClientException $exception) {

            if ($exception->getCode() == 401) {

                $this->reconnect();

                return $this->allocateStream($bucket, $name);

            }

            throw new ServerException($exception->getMessage(), $exception->getCode(), $exception);

        }

        return $response->getBody();

    }

    /**

     * {@inheritdoc}

    /**

     * {@inheritdoc}

     */

    public function delete(BucketInterface $bucket, $name)

    {

        try {

            $this->client->send($this->buildRequest('DELETE', $bucket, $name));

        } catch (ClientException $exception) {

            if ($exception->getCode() == 401) {

                $this->reconnect();

                $this->delete($bucket, $name);

            } elseif ($exception->getCode() != 404) {

                throw new ServerException($exception->getMessage(), $exception->getCode(),

                    $exception);

            }

        }

    }

    /**

     * {@inheritdoc}