From 5b1b259ab876100168ce30d1970936b9bf33ab90 Mon Sep 17 00:00:00 2001
From: Tihomir Krasimirov Mateev <tihomir.mateev@redis.com>
Date: Wed, 30 Oct 2024 22:33:44 +0200
Subject: [PATCH] Run reactive MGET in parallel #2395 (#3036)

---
 .../cluster/RedisAdvancedClusterReactiveCommandsImpl.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterReactiveCommandsImpl.java b/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterReactiveCommandsImpl.java
index f0d97fe708..b3c9ff503d 100644
--- a/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterReactiveCommandsImpl.java
+++ b/src/main/java/io/lettuce/core/cluster/RedisAdvancedClusterReactiveCommandsImpl.java
@@ -284,7 +284,7 @@ public Flux<KeyValue<K, V>> mget(Iterable<K> keys) {
             publishers.add(super.mget(entry.getValue()));
         }
 
-        Flux<KeyValue<K, V>> fluxes = Flux.concat(publishers);
+        Flux<KeyValue<K, V>> fluxes = Flux.mergeSequential(publishers);
 
         Mono<List<KeyValue<K, V>>> map = fluxes.collectList().map(vs -> {
 
@@ -333,7 +333,7 @@ public Mono<Long> mget(KeyValueStreamingChannel<K, V> channel, Iterable<K> keys)
             publishers.add(super.mget(channel, entry.getValue()));
         }
 
-        return Flux.merge(publishers).reduce((accu, next) -> accu + next);
+        return Flux.merge(publishers).reduce(Long::sum);
     }
 
     @Override