Skip to content

Commit

Permalink
refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
Nikita committed Sep 25, 2016
1 parent 70ffe42 commit 305d9bb
Showing 1 changed file with 2 additions and 2 deletions.
Expand Up @@ -199,7 +199,7 @@ public void operationComplete(Future<Void> future) throws Exception {
return;
}

List<BatchCommandData<?, ?>> entries = new ArrayList<BatchCommandData<?, ?>>();
List<BatchCommandData> entries = new ArrayList<BatchCommandData>();
for (Entry e : commands.values()) {
entries.addAll(e.getCommands());
}
Expand Down Expand Up @@ -369,7 +369,7 @@ public void run(Timeout timeout) throws Exception {

private void checkConnectionFuture(final Entry entry, final NodeSource source,
final RPromise<Void> mainPromise, final RPromise<Void> attemptPromise, final AsyncDetails details,
RFuture<RedisConnection> connFuture, boolean noResult) {
RFuture<RedisConnection> connFuture, final boolean noResult) {
if (attemptPromise.isDone() || mainPromise.isCancelled() || connFuture.isCancelled()) {
return;
}
Expand Down

0 comments on commit 305d9bb

Please sign in to comment.