@Test void scrollIterableShouldWorkWhenEmpty() { SearchRequest searchRequest = new SearchRequest(INDEX_NAME.getValue()) .scroll(TIMEOUT) .source(new SearchSourceBuilder() .query(QueryBuilders.matchAllQuery()) .size(SIZE)); assertThat(new ScrolledSearch(client, searchRequest).searchHits().collectList().block()) .isEmpty(); }
public Flux<SearchHit> searchHits() { return searchResponses() .concatMap(searchResponse -> Flux.just(searchResponse.getHits().getHits())); }
ScrolledSearch { public Flux<SearchHit> searchHits() { return searchResponses() .concatMap(searchResponse -> Flux.just(searchResponse.getHits().getHits())); } }
ScrolledSearch { public Flux<SearchHit> searchHits() { return searchResponses() .concatMap(searchResponse -> Flux.just(searchResponse.getHits().getHits())); } ScrolledSearch(ReactorElasticSearchClient client, SearchRequest searchRequest); }
ScrolledSearch { public Flux<SearchHit> searchHits() { return searchResponses() .concatMap(searchResponse -> Flux.just(searchResponse.getHits().getHits())); } ScrolledSearch(ReactorElasticSearchClient client, SearchRequest searchRequest); Flux<SearchHit> searchHits(); Flux<SearchResponse> searchResponses(); void close(AtomicReference<Optional<String>> scrollId); }
ScrolledSearch { public Flux<SearchHit> searchHits() { return searchResponses() .concatMap(searchResponse -> Flux.just(searchResponse.getHits().getHits())); } ScrolledSearch(ReactorElasticSearchClient client, SearchRequest searchRequest); Flux<SearchHit> searchHits(); Flux<SearchResponse> searchResponses(); void close(AtomicReference<Optional<String>> scrollId);  }