@Test void scrollRequest() { request.setScrollId("scroll123"); assertEquals( new SearchScrollRequest() .scroll(ElasticsearchScrollRequest.DEFAULT_SCROLL_TIMEOUT) .scrollId("scroll123"), request.scrollRequest()); }
public SearchScrollRequest scrollRequest() { Objects.requireNonNull(scrollId, "Scroll id cannot be null"); return new SearchScrollRequest().scroll(DEFAULT_SCROLL_TIMEOUT).scrollId(scrollId); }
ElasticsearchScrollRequest implements ElasticsearchRequest { public SearchScrollRequest scrollRequest() { Objects.requireNonNull(scrollId, "Scroll id cannot be null"); return new SearchScrollRequest().scroll(DEFAULT_SCROLL_TIMEOUT).scrollId(scrollId); } }
ElasticsearchScrollRequest implements ElasticsearchRequest { public SearchScrollRequest scrollRequest() { Objects.requireNonNull(scrollId, "Scroll id cannot be null"); return new SearchScrollRequest().scroll(DEFAULT_SCROLL_TIMEOUT).scrollId(scrollId); }  }
ElasticsearchScrollRequest implements ElasticsearchRequest { public SearchScrollRequest scrollRequest() { Objects.requireNonNull(scrollId, "Scroll id cannot be null"); return new SearchScrollRequest().scroll(DEFAULT_SCROLL_TIMEOUT).scrollId(scrollId); }  @Override ElasticsearchResponse search(Function<SearchRequest, SearchResponse> searchAction,
                                      Function<SearchScrollRequest, SearchResponse> scrollAction); @Override void clean(Consumer<String> cleanAction); SearchRequest searchRequest(); boolean isScrollStarted(); SearchScrollRequest scrollRequest(); void reset(); }
ElasticsearchScrollRequest implements ElasticsearchRequest { public SearchScrollRequest scrollRequest() { Objects.requireNonNull(scrollId, "Scroll id cannot be null"); return new SearchScrollRequest().scroll(DEFAULT_SCROLL_TIMEOUT).scrollId(scrollId); }  @Override ElasticsearchResponse search(Function<SearchRequest, SearchResponse> searchAction,
                                      Function<SearchScrollRequest, SearchResponse> scrollAction); @Override void clean(Consumer<String> cleanAction); SearchRequest searchRequest(); boolean isScrollStarted(); SearchScrollRequest scrollRequest(); void reset(); static final TimeValue DEFAULT_SCROLL_TIMEOUT; }