Skip to content

Commit

Permalink
refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
Nikita committed Dec 28, 2017
1 parent 3e1d5a6 commit dee6593
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion redisson/src/main/java/org/redisson/api/RBloomFilter.java
Expand Up @@ -53,6 +53,6 @@ public interface RBloomFilter<T> extends RExpirable {
* *
* @return probabilistic number of elements * @return probabilistic number of elements
*/ */
int count(); long count();


} }
Expand Up @@ -196,7 +196,7 @@ public <R> RFuture<R> executeAsync(int syncSlaves, long syncTimeout, boolean ski
} }


RPromise<R> resultPromise; RPromise<R> resultPromise;
RPromise<Void> voidPromise = new RedissonPromise<Void>(); final RPromise<Void> voidPromise = new RedissonPromise<Void>();
if (skipResult) { if (skipResult) {
voidPromise.addListener(new FutureListener<Void>() { voidPromise.addListener(new FutureListener<Void>() {
@Override @Override
Expand Down Expand Up @@ -245,7 +245,7 @@ public void operationComplete(Future<Void> future) throws Exception {
resultPromise = (RPromise<R>) promise; resultPromise = (RPromise<R>) promise;
} }


AtomicInteger slots = new AtomicInteger(commands.size()); final AtomicInteger slots = new AtomicInteger(commands.size());


for (java.util.Map.Entry<RFuture<?>, List<CommandBatchService>> entry : nestedServices.entrySet()) { for (java.util.Map.Entry<RFuture<?>, List<CommandBatchService>> entry : nestedServices.entrySet()) {
slots.incrementAndGet(); slots.incrementAndGet();
Expand Down

0 comments on commit dee6593

Please sign in to comment.