code: private void unsubscribeAndRetry(final Subscription subscription, final CouchbaseRequest request) {
          if (subscription != null && !subscription.isUnsubscribed()) {
              subscription.unsubscribe();
          }
          RetryHelper.retryOrCancel(env, request, responseBuffer);
      }
docs: Helper method to unsubscribe from the subscription and send the request into retry.