code: public static void retry(final CouchbaseRequest request, final EventSink<ResponseEvent> responseBuffer) {
          if(!responseBuffer.tryPublishEvent(ResponseHandler.RESPONSE_TRANSLATOR, request, request.observable())) {
              request.observable().onError(CouchbaseCore.BACKPRESSURE_EXCEPTION);
          }
      }
docs: Always retry the request and send it into the response buffer.
  
  @param request the request to retry
  @param responseBuffer the response buffer to send it into.