File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -71,13 +71,14 @@ You can enable indexing metrics for a query by setting the `PopulateIndexMetrics
71
71
72
72
CosmosPagedFlux<JsonNode > items = container. queryItems(querySpec, options, JsonNode . class);
73
73
74
- items. byPage(). toIterable(). forEach(itemsResponse - > {
75
- logger. info(" Query item diagnostics through iterableByPage : {}" ,
76
- itemsResponse. getCosmosDiagnostics());
74
+ items. byPage(100 ). flatMap(itemsResponse - > {
75
+ logger. info(" diagnostics: {}" ,itemsResponse. getCosmosDiagnostics());
77
76
for (JsonNode item : itemsResponse. getResults()) {
78
77
logger. info(" Item: {}" , item. toString());
79
78
}
80
- });
79
+ executeCountQueryPrintSingleResultNumber. incrementAndGet();
80
+ return Flux . just(itemsResponse);
81
+ }). blockLast();
81
82
```
82
83
---
83
84
You can’t perform that action at this time.
0 commit comments