Run reactive MGET in parallel #2395

Original pull request: #2396
redis · Apr 24, 2023 · 07ec489 · 07ec489
1 parent 6604fbe
commit 07ec489
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 -> {