RxRedisClientConfig config = new RxRedisClientConfig();
RxRedisClient client = new RxRedisClient(config);
//...
Observable<Response> batch = client.sendBatch(
new Command("SET", "key1", "value1"),
new Command("GET", "key2")
);
batch.subscribe(response -> {
}, error -> {
});
Observable<Response> pipeline = client.sendPipeline(
new Command("SET", "key1", "value1"),
new Command("GET", "key2")
);
pipeline.subscribe(response -> {
}, error -> {
});
client.get("key").subscribe(value -> {
}, error -> {
});
RxRedisClientConfig config = new RxRedisClientConfig();
//...
