bulk.java

List<JsonDocument> foundDocs = Observable
    .from(Arrays.asList("id1", "id2"))
    .flatMap(new Func1<String, Observable<JsonDocument>>() {
        @Override
        public Observable<JsonDocument> call(String id) {
            return bucket.async().get(id);
        }
    })
    .toList()
    .timeout(5, TimeUnit.SECONDS)
    .toBlocking()
    .single();