From 0004641a6e1546e24b27b8548cfd32f4ada185d0 Mon Sep 17 00:00:00 2001
From: stexxen <steven.pearce@nowyoyo.com>
Date: Sat, 2 Oct 2021 21:13:27 +0100
Subject: [PATCH] in method searchForStream use Query scrolltime if set,
 otherwise default to 60 seconds as before.

---
 .../elasticsearch/core/AbstractElasticsearchTemplate.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/springframework/data/elasticsearch/core/AbstractElasticsearchTemplate.java b/src/main/java/org/springframework/data/elasticsearch/core/AbstractElasticsearchTemplate.java
index 590fa1613..20ed1b86f 100644
--- a/src/main/java/org/springframework/data/elasticsearch/core/AbstractElasticsearchTemplate.java
+++ b/src/main/java/org/springframework/data/elasticsearch/core/AbstractElasticsearchTemplate.java
@@ -69,6 +69,7 @@
  * @author Peter-Josef Meisch
  * @author Roman Puchkovskiy
  * @author Subhobrata Dey
+ * @author Steven Pearce
  */
 public abstract class AbstractElasticsearchTemplate implements ElasticsearchOperations, ApplicationContextAware {
 
@@ -370,7 +371,8 @@ public <T> SearchHitsIterator<T> searchForStream(Query query, Class<T> clazz) {
 	@Override
 	public <T> SearchHitsIterator<T> searchForStream(Query query, Class<T> clazz, IndexCoordinates index) {
 
-		long scrollTimeInMillis = Duration.ofMinutes(1).toMillis();
+		Duration scrollTime = query.getScrollTime() != null ? query.getScrollTime() : Duration.ofMinutes(1);
+		long scrollTimeInMillis = scrollTime.toMillis();
 		// noinspection ConstantConditions
 		int maxCount = query.isLimiting() ? query.getMaxResults() : 0;