code: private void scheduleWorker(Scheduler scheduler, final CouchbaseResponse response,
          final Subject<CouchbaseResponse, CouchbaseResponse> observable) {
          final Scheduler.Worker worker = scheduler.createWorker();
          worker.schedule(new Action0() {
              @Override
              public void call() {
                  completeResponse(response, observable);
                  worker.unsubscribe();
              }
          });
      }
docs: Dispatches the response on a generic scheduler through creating a worker.