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