From 113ba7865a780f0fc3dffbab328043f9e0382a65 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Sat, 6 Jan 2018 13:57:13 +0300
Subject: [PATCH] refactoring

---
 .../java/org/redisson/RedissonBitSet.java     | 19 ++++++-------------
 1 file changed, 6 insertions(+), 13 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/RedissonBitSet.java b/redisson/src/main/java/org/redisson/RedissonBitSet.java
index 4b90271ea..424a9c1e5 100644
--- a/redisson/src/main/java/org/redisson/RedissonBitSet.java
+++ b/redisson/src/main/java/org/redisson/RedissonBitSet.java
@@ -202,19 +202,16 @@ public class RedissonBitSet extends RedissonExpirable implements RBitSet {
 
     @Override
     public RFuture<Void> setAsync(long fromIndex, long toIndex, boolean value) {
-        if (value) {
-            return setAsync(fromIndex, toIndex);
+        CommandBatchService executorService = new CommandBatchService(commandExecutor.getConnectionManager());
+        for (long i = fromIndex; i < toIndex; i++) {
+            executorService.writeAsync(getName(), codec, RedisCommands.SETBIT_VOID, getName(), i, value ? 1 : 0);
         }
-        return clearAsync(fromIndex, toIndex);
+        return executorService.executeAsyncVoid();
     }
 
     @Override
     public RFuture<Void> clearAsync(long fromIndex, long toIndex) {
-        CommandBatchService executorService = new CommandBatchService(commandExecutor.getConnectionManager());
-        for (long i = fromIndex; i < toIndex; i++) {
-            executorService.writeAsync(getName(), codec, RedisCommands.SETBIT_VOID, getName(), i, 0);
-        }
-        return executorService.executeAsyncVoid();
+        return setAsync(fromIndex, toIndex, false);
     }
 
     @Override
@@ -229,11 +226,7 @@ public class RedissonBitSet extends RedissonExpirable implements RBitSet {
 
     @Override
     public RFuture<Void> setAsync(long fromIndex, long toIndex) {
-        CommandBatchService executorService = new CommandBatchService(commandExecutor.getConnectionManager());
-        for (long i = fromIndex; i < toIndex; i++) {
-            executorService.writeAsync(getName(), codec, RedisCommands.SETBIT_VOID, getName(), i, 1);
-        }
-        return executorService.executeAsyncVoid();
+        return setAsync(fromIndex, toIndex, true);
     }
 
     @Override
-- 
GitLab