code: protected void publishResponse(final CouchbaseResponse response,
          final Subject<CouchbaseResponse, CouchbaseResponse> observable) {
          if (response.status() != ResponseStatus.RETRY && observable != null) {
              if (moveResponseOut) {
                  Scheduler scheduler = env().scheduler();
                  if (scheduler instanceof CoreScheduler) {
                      scheduleDirect((CoreScheduler) scheduler, response, observable);
                  } else {
                      scheduleWorker(scheduler, response, observable);
                  }
              } else {
                  completeResponse(response, observable);
              }
          } else {
              responseBuffer.publishEvent(ResponseHandler.RESPONSE_TRANSLATOR, response, observable);
          }
      }
docs: Publishes a response with the attached observable.
  
  @param response the response to publish.
  @param observable pushing into the event sink.