Select support to pipeline. Thanks to @ib84
This commit is contained in:
@@ -1226,4 +1226,9 @@ public class Pipeline extends Queable {
|
|||||||
client.randomKey();
|
client.randomKey();
|
||||||
return getResponse(BuilderFactory.STRING);
|
return getResponse(BuilderFactory.STRING);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public Response<String> select(int index){
|
||||||
|
client.select(index);
|
||||||
|
return getResponse(BuilderFactory.STRING);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -101,6 +101,13 @@ public class PipeliningTest extends Assert {
|
|||||||
assertNotNull(score.get());
|
assertNotNull(score.get());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void pipelineSelect() {
|
||||||
|
Pipeline p = jedis.pipelined();
|
||||||
|
p.select(1);
|
||||||
|
p.sync();
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void pipelineResponseWithoutData() {
|
public void pipelineResponseWithoutData() {
|
||||||
jedis.zadd("zset", 1, "foo");
|
jedis.zadd("zset", 1, "foo");
|
||||||
|
|||||||
Reference in New Issue
Block a user