code.java

    final Scope scope = env.tracer()
      .buildSpan("query-and-fetch")
      .startActive(true);

    bucket.async()
      .query(N1qlQuery.simple("select meta().id as id from `travel-sample` limit 10"), scope.span())
      .flatMap(new Func1<AsyncN1qlQueryResult, Observable<AsyncN1qlQueryRow>>() {
        public Observable<AsyncN1qlQueryRow> call(AsyncN1qlQueryResult result) {
          return result.rows();
        }
      }).flatMap(new Func1<AsyncN1qlQueryRow, Observable<JsonDocument>>() {
      public Observable<JsonDocument> call(AsyncN1qlQueryRow row) {
        return bucket.async().get(row.value().getString("id"), scope.span(), JsonDocument.class);
      }
    })
      .toBlocking()
      .last();

    scope.close();