带有couchbase的rxjava是否为非批量操作提供价值

新的Couchbase SDK使批量操作易于使用，性能更高，使用rx-java。但是使用rx对单个值进行运算是否有任何价值？

如果我们看一个简单的CAS /插入操作，即如果该值存在，请执行cas else执行插入操作并返回文档值

    final String id = "id";
    final String modified = "modified";
    final int numCasRetries = 3;

    Observable
        .defer(() -> bucket.async().get(id))
        .flatMap(document -> {
            try {
                if (document == null) {
                    JsonObject content = JsonObject.create();
                    content.put(modified,  new Date().getTime());
                    document = bucket.insert(JsonDocument.create(id, content));
                } else {
                    document.content().put(modified, new Date().getTime());
                    document = bucket.replace(document);
                }
                return Observable.just(document);
            } catch (CASMismatchException e) {
                return Observable.error(e);
            }
        })
        .retry((count, error) -> {
            // Only retry on CASMismatchException
            return ((error instanceof CASMismatchException)
                    && (count < numCASRetries));
        })
         .onErrorResumeNext(error -> {
            return Observable.error(new Exception(error));
        })
        .toBlocking()
        .single();

因此toBlocking将阻塞调用线程，直到结果可用为止。并且一次只能从Couchbase写入和读取一个值。所以我不明白为什么或者即使这段代码会比

    final String id = "id";
    final String modified = "modified";
    final int numCasRetries = 3;

    JsonDocument document = null;
    for (int i = 1; i <= numCasRetries; i++) {
        document = bucket.get(id);
        try {
            if (document == null) {
                JsonObject content = JsonObject.create();
                content.put(modified,  new Date().getTime());
                document = bucket.insert(JsonDocument.create(id, content));
            } else {
                document.content().put(modified, new Date().getTime());
                document = bucket.replace(document);
            } 
            return document;
        } catch (CASMismatchException e) {
            if (i == numCasRetries) {
                throw e;
            }
        }
    }

如果有什么话，我认为在这种情况下，rx方法的可读性较差。