Official Couchbase Java SDK Preview - Document Loading

gistfile1.java

// Load 3 Documents and process them one after another

// Java 8:
    Observable
      .from("doc1", "doc2", "doc3")
      .flatMap(id -> bucket.get(id))
      .subscribe(doc -> System.out.println(doc));
      
// Java 6 & 7
    Observable
      .from("doc1", "doc2", "doc3")
      .flatMap(new Func1<String, Observable<Document>>() {
        @Override
        public Observable<Document> call(String id) {
          return bucket.get(id);
        }
      })
      .subscribe(new Action1<Document>() {
        @Override
        public void call(Document doc) {
          System.out.println(doc);
        }
      });

gistfile2.java

// Load 3 Documents and process them together

// Java 8:
    Observable
      .from("doc1", "doc2", "doc3")
      .flatMap(id -> bucket.get(id))
      .toList()
      .subscribe(docs -> System.out.println(docs));
      
// Java 6 & 7
    Observable
      .from("doc1", "doc2", "doc3")
      .flatMap(new Func1<String, Observable<Document>>() {
        @Override
        public Observable<Document> call(String id) {
          return bucket.get(id);
        }
      })
      .toList()
      .subscribe(new Action1<List<Document>>() {
        @Override
        public void call(List<Document> docs) {
          System.out.println(docs)
        }
      }
    );