diff --git a/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java b/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java index d91175a..b63ad09 100644 --- a/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java +++ b/spring-session-data-geode/src/main/java/org/springframework/session/data/gemfire/GemFireOperationsSessionRepository.java @@ -74,15 +74,14 @@ public class GemFireOperationsSessionRepository extends AbstractGemFireOperation * @see java.util.Map * @see #prepareQuery(String) */ + @Override public Map findByIndexNameAndIndexValue(String indexName, String indexValue) { SelectResults results = getTemplate().find(prepareQuery(indexName), indexValue); Map sessions = new HashMap<>(results.size()); - for (Session session : results.asList()) { - sessions.put(session.getId(), session); - } + results.asList().forEach(session -> sessions.put(session.getId(), session)); return sessions; }