Pipeline.exec() now returns a response
This commit is contained in:
@@ -1218,10 +1218,11 @@ public class Pipeline extends Queable {
|
|||||||
return getResponse(BuilderFactory.STRING);
|
return getResponse(BuilderFactory.STRING);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void exec() {
|
public Response<List<Object>> exec() {
|
||||||
client.exec();
|
client.exec();
|
||||||
super.getResponse(currentMulti);
|
Response<List<Object>> response = super.getResponse(currentMulti);
|
||||||
currentMulti = null;
|
currentMulti = null;
|
||||||
|
return response;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void multi() {
|
public void multi() {
|
||||||
@@ -1279,5 +1280,4 @@ public class Pipeline extends Queable {
|
|||||||
client.select(index);
|
client.select(index);
|
||||||
return getResponse(BuilderFactory.STRING);
|
return getResponse(BuilderFactory.STRING);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -171,7 +171,7 @@ public class PipeliningTest extends Assert {
|
|||||||
p.multi();
|
p.multi();
|
||||||
Response<Long> r1 = p.hincrBy("a", "f1", -1);
|
Response<Long> r1 = p.hincrBy("a", "f1", -1);
|
||||||
Response<Long> r2 = p.hincrBy("a", "f1", -2);
|
Response<Long> r2 = p.hincrBy("a", "f1", -2);
|
||||||
p.exec();
|
Response<List<Object>> r3 = p.exec();
|
||||||
List<Object> result = p.syncAndReturnAll();
|
List<Object> result = p.syncAndReturnAll();
|
||||||
|
|
||||||
assertEquals(new Long(-1), r1.get());
|
assertEquals(new Long(-1), r1.get());
|
||||||
@@ -188,5 +188,9 @@ public class PipeliningTest extends Assert {
|
|||||||
List<Object> multiResult = (List<Object>) result.get(3);
|
List<Object> multiResult = (List<Object>) result.get(3);
|
||||||
assertEquals(new Long(-1), multiResult.get(0));
|
assertEquals(new Long(-1), multiResult.get(0));
|
||||||
assertEquals(new Long(-3), multiResult.get(1));
|
assertEquals(new Long(-3), multiResult.get(1));
|
||||||
|
|
||||||
|
assertEquals(new Long(-1), r3.get().get(0));
|
||||||
|
assertEquals(new Long(-3), r3.get().get(1));
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user