code: private static <T> Func1<List<JsonObject>, Observable<T>> errorsToThrowable(final String messagePrefix) {
          return new Func1<List<JsonObject>, Observable<T>>() {
              @Override
              public Observable<T> call(List<JsonObject> errors) {
                  return Observable.<T>error(new CouchbaseException(messagePrefix + errors));
              }
          };
      }
docs: /*==== INDEX MANAGEMENT ====