Fixed - UnsupportedOperationException is thrown if Spring Data Redis connection executed in pipelined mode. #3021

redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java

@@ -1450,6 +1450,10 @@ public class RedissonConnection extends AbstractRedisConnection {
     }
 
     protected void filterResults(BatchResult<?> result) {
+        if (result.getResponses().isEmpty()) {
+            return;
+        }
+
         int t = 0;
         for (Integer index : indexToRemove) {
             index -= t;

redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java

@@ -1507,6 +1507,10 @@ public class RedissonConnection extends AbstractRedisConnection {
     }
 
     protected void filterResults(BatchResult<?> result) {
+        if (result.getResponses().isEmpty()) {
+            return;
+        }
+
         int t = 0;
         for (Integer index : indexToRemove) {
             index -= t;

redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java

@@ -1523,6 +1523,10 @@ public class RedissonConnection extends AbstractRedisConnection {
     }
 
     protected void filterResults(BatchResult<?> result) {
+        if (result.getResponses().isEmpty()) {
+            return;
+        }
+
         int t = 0;
         for (Integer index : indexToRemove) {
             index -= t;

redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java

@@ -1507,6 +1507,10 @@ public class RedissonConnection extends AbstractRedisConnection {
     }
 
     protected void filterResults(BatchResult<?> result) {
+        if (result.getResponses().isEmpty()) {
+            return;
+        }
+
         int t = 0;
         for (Integer index : indexToRemove) {
             index -= t;

redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java

@@ -1542,6 +1542,10 @@ public class RedissonConnection extends AbstractRedisConnection {
     }
 
     protected void filterResults(BatchResult<?> result) {
+        if (result.getResponses().isEmpty()) {
+            return;
+        }
+
         int t = 0;
         for (Integer index : indexToRemove) {
             index -= t;

redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java

@@ -1534,6 +1534,10 @@ public class RedissonConnection extends AbstractRedisConnection {
     }
 
     protected void filterResults(BatchResult<?> result) {
+        if (result.getResponses().isEmpty()) {
+            return;
+        }
+
         int t = 0;
         for (Integer index : indexToRemove) {
             index -= t;

redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java

@@ -1534,6 +1534,10 @@ public class RedissonConnection extends AbstractRedisConnection {
     }
 
     protected void filterResults(BatchResult<?> result) {
+        if (result.getResponses().isEmpty()) {
+            return;
+        }
+
         int t = 0;
         for (Integer index : indexToRemove) {
             index -= t;