Browse Source

ScanParams.SCAN_POINTER_START.equals(cursorStr) 改为 scanResult.isCompleteIteration()

James 2 years ago
parent
commit
55d3bc0bd6
1 changed files with 2 additions and 2 deletions
  1. 2 2
      src/main/java/com/jfinal/plugin/redis/Cache.java

+ 2 - 2
src/main/java/com/jfinal/plugin/redis/Cache.java

@@ -1704,8 +1704,8 @@ public class Cache {
                 List<String> list = scanResult.getResult();
                 List<String> list = scanResult.getResult();
                 // scanResult.getResult().size() 有时为 0
                 // scanResult.getResult().size() 有时为 0
                 continueScan = list != null && list.size() > 0 ? keyList.call(list) : true;
                 continueScan = list != null && list.size() > 0 ? keyList.call(list) : true;
-            } while (continueScan && !ScanParams.SCAN_POINTER_START.equals(cursorStr));
-            // } while (continueScan && !scanResult.isCompleteIteration());
+            // } while (continueScan && !ScanParams.SCAN_POINTER_START.equals(cursorStr));
+            } while (continueScan && !scanResult.isCompleteIteration());
         }
         }
         finally {close(jedis);}
         finally {close(jedis);}
     }
     }