From 7b456ba3e7259d9aa3dc5482f59a810799796a04 Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Mon, 30 Mar 2020 15:01:01 +0300
Subject: [PATCH] refactoring

---
 .../spring/data/connection/RedissonConnection.java        | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
index d9519426d..52658e90b 100644
--- a/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
+++ b/redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
@@ -267,11 +267,11 @@ public class RedissonConnection extends AbstractRedisConnection {
         final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
         final AtomicLong count = new AtomicLong();
         final AtomicLong executed = new AtomicLong(range2key.size());
-        BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
+        BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
             @Override
-            public void accept(List<?> r, Throwable u) {
+            public void accept(BatchResult<?> r, Throwable u) {
                 if (u == null) {    
-                    List<Long> result = (List<Long>) r;
+                    List<Long> result = (List<Long>) r.getResponses();
                     for (Long res : result) {
                         if (res != null) {
                             count.addAndGet(res);
@@ -291,7 +291,7 @@ public class RedissonConnection extends AbstractRedisConnection {
                 es.writeAsync(entry.getKey(), null, command, key);
             }
 
-            RFuture<List<?>> future = es.executeAsync();
+            RFuture<BatchResult<?>> future = es.executeAsync();
             future.onComplete(listener);
         }