package io.vertx.reactivex.redis.client;
import io.vertx.reactivex.RxHelper;
import io.vertx.reactivex.ObservableHelper;
import io.vertx.reactivex.FlowableHelper;
import io.vertx.reactivex.impl.AsyncResultMaybe;
import io.vertx.reactivex.impl.AsyncResultSingle;
import io.vertx.reactivex.impl.AsyncResultCompletable;
import io.vertx.reactivex.WriteStreamObserver;
import io.vertx.reactivex.WriteStreamSubscriber;
import java.util.Map;
import java.util.Set;
import java.util.List;
import java.util.Iterator;
import java.util.function.Function;
import java.util.stream.Collectors;
import io.vertx.core.Handler;
import io.vertx.core.AsyncResult;
import io.vertx.core.json.JsonObject;
import io.vertx.core.json.JsonArray;
import io.vertx.lang.rx.RxGen;
import io.vertx.lang.rx.TypeArg;
import io.vertx.lang.rx.MappingIterator;
@RxGen(io.vertx.redis.client.RedisAPI.class)
public class RedisAPI {
@Override
public String toString() {
return delegate.toString();
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
RedisAPI that = (RedisAPI) o;
return delegate.equals(that.delegate);
}
@Override
public int hashCode() {
return delegate.hashCode();
}
public static final TypeArg<RedisAPI> __TYPE_ARG = new TypeArg<>( obj -> new RedisAPI((io.vertx.redis.client.RedisAPI) obj),
RedisAPI::getDelegate
);
private final io.vertx.redis.client.RedisAPI delegate;
public RedisAPI(io.vertx.redis.client.RedisAPI delegate) {
this.delegate = delegate;
}
public RedisAPI(Object delegate) {
this.delegate = (io.vertx.redis.client.RedisAPI)delegate;
}
public io.vertx.redis.client.RedisAPI getDelegate() {
return delegate;
}
public void close() {
delegate.close();
}
public io.vertx.reactivex.redis.client.RedisAPI acl(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.acl(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI acl(List<String> args) {
return
acl(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxAcl(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
acl(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI append(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.append(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI append(String arg0, String arg1) {
return
append(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxAppend(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
append(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI asking(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.asking(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI asking() {
return
asking(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxAsking() {
return AsyncResultMaybe.toMaybe($handler -> {
asking($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI auth(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.auth(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI auth(List<String> args) {
return
auth(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxAuth(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
auth(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bgrewriteaof(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bgrewriteaof(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bgrewriteaof() {
return
bgrewriteaof(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBgrewriteaof() {
return AsyncResultMaybe.toMaybe($handler -> {
bgrewriteaof($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bgsave(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bgsave(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bgsave(List<String> args) {
return
bgsave(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBgsave(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bgsave(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bitcount(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bitcount(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bitcount(List<String> args) {
return
bitcount(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBitcount(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bitcount(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bitfield(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bitfield(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bitfield(List<String> args) {
return
bitfield(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBitfield(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bitfield(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bitfieldRo(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bitfieldRo(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bitfieldRo(List<String> args) {
return
bitfieldRo(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBitfieldRo(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bitfieldRo(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bitop(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bitop(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bitop(List<String> args) {
return
bitop(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBitop(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bitop(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bitpos(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bitpos(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bitpos(List<String> args) {
return
bitpos(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBitpos(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bitpos(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI blpop(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.blpop(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI blpop(List<String> args) {
return
blpop(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBlpop(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
blpop(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI brpop(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.brpop(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI brpop(List<String> args) {
return
brpop(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBrpop(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
brpop(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI brpoplpush(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.brpoplpush(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI brpoplpush(String arg0, String arg1, String arg2) {
return
brpoplpush(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBrpoplpush(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
brpoplpush(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bzpopmax(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bzpopmax(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bzpopmax(List<String> args) {
return
bzpopmax(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBzpopmax(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bzpopmax(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI bzpopmin(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.bzpopmin(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI bzpopmin(List<String> args) {
return
bzpopmin(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxBzpopmin(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
bzpopmin(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI client(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.client(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI client(List<String> args) {
return
client(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxClient(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
client(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI cluster(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.cluster(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI cluster(List<String> args) {
return
cluster(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxCluster(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
cluster(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI command(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.command(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI command(List<String> args) {
return
command(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxCommand(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
command(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI config(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.config(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI config(List<String> args) {
return
config(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxConfig(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
config(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI dbsize(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.dbsize(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI dbsize() {
return
dbsize(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxDbsize() {
return AsyncResultMaybe.toMaybe($handler -> {
dbsize($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI debug(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.debug(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI debug(List<String> args) {
return
debug(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxDebug(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
debug(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI decr(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.decr(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI decr(String arg0) {
return
decr(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxDecr(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
decr(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI decrby(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.decrby(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI decrby(String arg0, String arg1) {
return
decrby(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxDecrby(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
decrby(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI del(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.del(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI del(List<String> args) {
return
del(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxDel(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
del(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI discard(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.discard(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI discard() {
return
discard(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxDiscard() {
return AsyncResultMaybe.toMaybe($handler -> {
discard($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI dump(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.dump(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI dump(String arg0) {
return
dump(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxDump(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
dump(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI echo(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.echo(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI echo(String arg0) {
return
echo(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxEcho(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
echo(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI eval(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.eval(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI eval(List<String> args) {
return
eval(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxEval(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
eval(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI evalsha(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.evalsha(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI evalsha(List<String> args) {
return
evalsha(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxEvalsha(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
evalsha(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI exec(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.exec(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI exec() {
return
exec(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxExec() {
return AsyncResultMaybe.toMaybe($handler -> {
exec($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI exists(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.exists(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI exists(List<String> args) {
return
exists(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxExists(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
exists(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI expire(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.expire(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI expire(String arg0, String arg1) {
return
expire(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxExpire(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
expire(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI expireat(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.expireat(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI expireat(String arg0, String arg1) {
return
expireat(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxExpireat(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
expireat(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI flushall(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.flushall(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI flushall(List<String> args) {
return
flushall(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxFlushall(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
flushall(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI flushdb(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.flushdb(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI flushdb(List<String> args) {
return
flushdb(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxFlushdb(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
flushdb(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI geoadd(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.geoadd(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI geoadd(List<String> args) {
return
geoadd(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeoadd(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
geoadd(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI geodist(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.geodist(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI geodist(List<String> args) {
return
geodist(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeodist(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
geodist(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI geohash(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.geohash(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI geohash(List<String> args) {
return
geohash(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeohash(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
geohash(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI geopos(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.geopos(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI geopos(List<String> args) {
return
geopos(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeopos(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
geopos(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI georadius(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.georadius(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI georadius(List<String> args) {
return
georadius(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeoradius(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
georadius(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI georadiusRo(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.georadiusRo(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI georadiusRo(List<String> args) {
return
georadiusRo(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeoradiusRo(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
georadiusRo(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI georadiusbymember(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.georadiusbymember(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI georadiusbymember(List<String> args) {
return
georadiusbymember(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeoradiusbymember(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
georadiusbymember(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI georadiusbymemberRo(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.georadiusbymemberRo(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI georadiusbymemberRo(List<String> args) {
return
georadiusbymemberRo(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGeoradiusbymemberRo(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
georadiusbymemberRo(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI get(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.get(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI get(String arg0) {
return
get(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGet(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
get(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI getbit(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.getbit(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI getbit(String arg0, String arg1) {
return
getbit(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGetbit(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
getbit(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI getrange(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.getrange(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI getrange(String arg0, String arg1, String arg2) {
return
getrange(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGetrange(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
getrange(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI getset(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.getset(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI getset(String arg0, String arg1) {
return
getset(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxGetset(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
getset(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hdel(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hdel(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hdel(List<String> args) {
return
hdel(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHdel(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
hdel(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hello(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hello(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hello(List<String> args) {
return
hello(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHello(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
hello(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hexists(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hexists(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hexists(String arg0, String arg1) {
return
hexists(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHexists(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
hexists(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hget(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hget(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hget(String arg0, String arg1) {
return
hget(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHget(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
hget(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hgetall(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hgetall(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hgetall(String arg0) {
return
hgetall(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHgetall(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
hgetall(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hincrby(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hincrby(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hincrby(String arg0, String arg1, String arg2) {
return
hincrby(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHincrby(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
hincrby(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hincrbyfloat(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hincrbyfloat(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hincrbyfloat(String arg0, String arg1, String arg2) {
return
hincrbyfloat(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHincrbyfloat(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
hincrbyfloat(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hkeys(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hkeys(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hkeys(String arg0) {
return
hkeys(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHkeys(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
hkeys(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hlen(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hlen(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hlen(String arg0) {
return
hlen(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHlen(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
hlen(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hmget(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hmget(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hmget(List<String> args) {
return
hmget(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHmget(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
hmget(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hmset(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hmset(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hmset(List<String> args) {
return
hmset(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHmset(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
hmset(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI host(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.host(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI host(List<String> args) {
return
host(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHost(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
host(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hscan(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hscan(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hscan(List<String> args) {
return
hscan(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHscan(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
hscan(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hset(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hset(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hset(List<String> args) {
return
hset(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHset(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
hset(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hsetnx(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hsetnx(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hsetnx(String arg0, String arg1, String arg2) {
return
hsetnx(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHsetnx(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
hsetnx(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hstrlen(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hstrlen(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hstrlen(String arg0, String arg1) {
return
hstrlen(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHstrlen(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
hstrlen(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI hvals(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.hvals(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI hvals(String arg0) {
return
hvals(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxHvals(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
hvals(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI incr(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.incr(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI incr(String arg0) {
return
incr(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxIncr(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
incr(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI incrby(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.incrby(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI incrby(String arg0, String arg1) {
return
incrby(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxIncrby(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
incrby(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI incrbyfloat(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.incrbyfloat(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI incrbyfloat(String arg0, String arg1) {
return
incrbyfloat(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxIncrbyfloat(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
incrbyfloat(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI info(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.info(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI info(List<String> args) {
return
info(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxInfo(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
info(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI keys(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.keys(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI keys(String arg0) {
return
keys(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxKeys(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
keys(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lastsave(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lastsave(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lastsave() {
return
lastsave(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLastsave() {
return AsyncResultMaybe.toMaybe($handler -> {
lastsave($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI latency(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.latency(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI latency(List<String> args) {
return
latency(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLatency(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
latency(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lindex(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lindex(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lindex(String arg0, String arg1) {
return
lindex(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLindex(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
lindex(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI linsert(String arg0, String arg1, String arg2, String arg3, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.linsert(arg0, arg1, arg2, arg3, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI linsert(String arg0, String arg1, String arg2, String arg3) {
return
linsert(arg0, arg1, arg2, arg3, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLinsert(String arg0, String arg1, String arg2, String arg3) {
return AsyncResultMaybe.toMaybe($handler -> {
linsert(arg0, arg1, arg2, arg3, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI llen(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.llen(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI llen(String arg0) {
return
llen(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLlen(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
llen(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lolwut(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lolwut(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lolwut(List<String> args) {
return
lolwut(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLolwut(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
lolwut(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lpop(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lpop(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lpop(String arg0) {
return
lpop(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLpop(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
lpop(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lpush(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lpush(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lpush(List<String> args) {
return
lpush(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLpush(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
lpush(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lpushx(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lpushx(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lpushx(List<String> args) {
return
lpushx(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLpushx(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
lpushx(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lrange(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lrange(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lrange(String arg0, String arg1, String arg2) {
return
lrange(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLrange(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
lrange(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lrem(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lrem(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lrem(String arg0, String arg1, String arg2) {
return
lrem(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLrem(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
lrem(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI lset(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.lset(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI lset(String arg0, String arg1, String arg2) {
return
lset(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLset(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
lset(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI ltrim(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.ltrim(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI ltrim(String arg0, String arg1, String arg2) {
return
ltrim(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxLtrim(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
ltrim(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI memory(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.memory(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI memory(List<String> args) {
return
memory(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMemory(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
memory(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI mget(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.mget(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI mget(List<String> args) {
return
mget(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMget(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
mget(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI migrate(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.migrate(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI migrate(List<String> args) {
return
migrate(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMigrate(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
migrate(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI module(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.module(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI module(List<String> args) {
return
module(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxModule(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
module(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI monitor(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.monitor(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI monitor() {
return
monitor(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMonitor() {
return AsyncResultMaybe.toMaybe($handler -> {
monitor($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI move(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.move(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI move(String arg0, String arg1) {
return
move(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMove(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
move(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI mset(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.mset(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI mset(List<String> args) {
return
mset(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMset(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
mset(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI msetnx(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.msetnx(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI msetnx(List<String> args) {
return
msetnx(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMsetnx(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
msetnx(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI multi(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.multi(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI multi() {
return
multi(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxMulti() {
return AsyncResultMaybe.toMaybe($handler -> {
multi($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI object(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.object(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI object(List<String> args) {
return
object(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxObject(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
object(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI persist(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.persist(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI persist(String arg0) {
return
persist(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPersist(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
persist(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pexpire(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pexpire(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pexpire(String arg0, String arg1) {
return
pexpire(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPexpire(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
pexpire(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pexpireat(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pexpireat(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pexpireat(String arg0, String arg1) {
return
pexpireat(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPexpireat(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
pexpireat(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pfadd(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pfadd(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pfadd(List<String> args) {
return
pfadd(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPfadd(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
pfadd(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pfcount(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pfcount(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pfcount(List<String> args) {
return
pfcount(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPfcount(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
pfcount(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pfdebug(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pfdebug(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pfdebug(List<String> args) {
return
pfdebug(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPfdebug(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
pfdebug(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pfmerge(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pfmerge(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pfmerge(List<String> args) {
return
pfmerge(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPfmerge(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
pfmerge(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pfselftest(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pfselftest(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pfselftest() {
return
pfselftest(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPfselftest() {
return AsyncResultMaybe.toMaybe($handler -> {
pfselftest($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI ping(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.ping(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI ping(List<String> args) {
return
ping(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPing(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
ping(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI post(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.post(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI post(List<String> args) {
return
post(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPost(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
post(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI psetex(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.psetex(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI psetex(String arg0, String arg1, String arg2) {
return
psetex(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPsetex(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
psetex(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI psubscribe(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.psubscribe(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI psubscribe(List<String> args) {
return
psubscribe(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPsubscribe(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
psubscribe(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI psync(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.psync(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI psync(String arg0, String arg1) {
return
psync(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPsync(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
psync(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pttl(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pttl(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pttl(String arg0) {
return
pttl(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPttl(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
pttl(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI publish(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.publish(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI publish(String arg0, String arg1) {
return
publish(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPublish(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
publish(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI pubsub(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.pubsub(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI pubsub(List<String> args) {
return
pubsub(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPubsub(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
pubsub(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI punsubscribe(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.punsubscribe(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI punsubscribe(List<String> args) {
return
punsubscribe(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxPunsubscribe(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
punsubscribe(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI randomkey(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.randomkey(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI randomkey() {
return
randomkey(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRandomkey() {
return AsyncResultMaybe.toMaybe($handler -> {
randomkey($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI readonly(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.readonly(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI readonly() {
return
readonly(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxReadonly() {
return AsyncResultMaybe.toMaybe($handler -> {
readonly($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI readwrite(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.readwrite(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI readwrite() {
return
readwrite(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxReadwrite() {
return AsyncResultMaybe.toMaybe($handler -> {
readwrite($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI rename(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.rename(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI rename(String arg0, String arg1) {
return
rename(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRename(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
rename(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI renamenx(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.renamenx(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI renamenx(String arg0, String arg1) {
return
renamenx(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRenamenx(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
renamenx(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI replconf(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.replconf(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI replconf(List<String> args) {
return
replconf(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxReplconf(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
replconf(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI replicaof(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.replicaof(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI replicaof(String arg0, String arg1) {
return
replicaof(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxReplicaof(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
replicaof(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI restore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.restore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI restore(List<String> args) {
return
restore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRestore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
restore(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI restoreAsking(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.restoreAsking(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI restoreAsking(List<String> args) {
return
restoreAsking(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRestoreAsking(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
restoreAsking(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI role(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.role(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI role() {
return
role(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRole() {
return AsyncResultMaybe.toMaybe($handler -> {
role($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI rpop(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.rpop(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI rpop(String arg0) {
return
rpop(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRpop(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
rpop(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI rpoplpush(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.rpoplpush(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI rpoplpush(String arg0, String arg1) {
return
rpoplpush(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRpoplpush(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
rpoplpush(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI rpush(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.rpush(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI rpush(List<String> args) {
return
rpush(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRpush(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
rpush(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI rpushx(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.rpushx(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI rpushx(List<String> args) {
return
rpushx(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxRpushx(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
rpushx(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sadd(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sadd(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sadd(List<String> args) {
return
sadd(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSadd(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sadd(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI save(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.save(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI save() {
return
save(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSave() {
return AsyncResultMaybe.toMaybe($handler -> {
save($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI scan(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.scan(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI scan(List<String> args) {
return
scan(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxScan(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
scan(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI scard(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.scard(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI scard(String arg0) {
return
scard(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxScard(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
scard(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI script(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.script(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI script(List<String> args) {
return
script(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxScript(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
script(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sdiff(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sdiff(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sdiff(List<String> args) {
return
sdiff(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSdiff(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sdiff(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sdiffstore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sdiffstore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sdiffstore(List<String> args) {
return
sdiffstore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSdiffstore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sdiffstore(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI select(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.select(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI select(String arg0) {
return
select(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSelect(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
select(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI set(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.set(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI set(List<String> args) {
return
set(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSet(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
set(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI setbit(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.setbit(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI setbit(String arg0, String arg1, String arg2) {
return
setbit(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSetbit(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
setbit(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI setex(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.setex(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI setex(String arg0, String arg1, String arg2) {
return
setex(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSetex(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
setex(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI setnx(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.setnx(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI setnx(String arg0, String arg1) {
return
setnx(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSetnx(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
setnx(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI setrange(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.setrange(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI setrange(String arg0, String arg1, String arg2) {
return
setrange(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSetrange(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
setrange(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI shutdown(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.shutdown(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI shutdown(List<String> args) {
return
shutdown(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxShutdown(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
shutdown(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sinter(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sinter(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sinter(List<String> args) {
return
sinter(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSinter(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sinter(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sinterstore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sinterstore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sinterstore(List<String> args) {
return
sinterstore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSinterstore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sinterstore(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sismember(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sismember(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sismember(String arg0, String arg1) {
return
sismember(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSismember(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
sismember(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI slaveof(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.slaveof(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI slaveof(String arg0, String arg1) {
return
slaveof(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSlaveof(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
slaveof(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI slowlog(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.slowlog(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI slowlog(List<String> args) {
return
slowlog(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSlowlog(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
slowlog(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI smembers(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.smembers(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI smembers(String arg0) {
return
smembers(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSmembers(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
smembers(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI smove(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.smove(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI smove(String arg0, String arg1, String arg2) {
return
smove(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSmove(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
smove(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sort(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sort(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sort(List<String> args) {
return
sort(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSort(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sort(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI spop(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.spop(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI spop(List<String> args) {
return
spop(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSpop(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
spop(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI srandmember(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.srandmember(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI srandmember(List<String> args) {
return
srandmember(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSrandmember(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
srandmember(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI srem(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.srem(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI srem(List<String> args) {
return
srem(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSrem(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
srem(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sscan(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sscan(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sscan(List<String> args) {
return
sscan(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSscan(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sscan(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI stralgo(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.stralgo(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI stralgo(List<String> args) {
return
stralgo(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxStralgo(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
stralgo(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI strlen(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.strlen(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI strlen(String arg0) {
return
strlen(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxStrlen(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
strlen(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI subscribe(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.subscribe(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI subscribe(List<String> args) {
return
subscribe(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSubscribe(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
subscribe(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI substr(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.substr(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI substr(String arg0, String arg1, String arg2) {
return
substr(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSubstr(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
substr(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sunion(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sunion(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sunion(List<String> args) {
return
sunion(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSunion(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sunion(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sunionstore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sunionstore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sunionstore(List<String> args) {
return
sunionstore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSunionstore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
sunionstore(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI swapdb(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.swapdb(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI swapdb(String arg0, String arg1) {
return
swapdb(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSwapdb(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
swapdb(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI sync(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.sync(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI sync() {
return
sync(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxSync() {
return AsyncResultMaybe.toMaybe($handler -> {
sync($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI time(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.time(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI time() {
return
time(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxTime() {
return AsyncResultMaybe.toMaybe($handler -> {
time($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI touch(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.touch(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI touch(List<String> args) {
return
touch(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxTouch(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
touch(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI ttl(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.ttl(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI ttl(String arg0) {
return
ttl(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxTtl(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
ttl(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI type(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.type(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI type(String arg0) {
return
type(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxType(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
type(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI unlink(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.unlink(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI unlink(List<String> args) {
return
unlink(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxUnlink(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
unlink(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI unsubscribe(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.unsubscribe(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI unsubscribe(List<String> args) {
return
unsubscribe(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxUnsubscribe(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
unsubscribe(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI unwatch(Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.unwatch(new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI unwatch() {
return
unwatch(ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxUnwatch() {
return AsyncResultMaybe.toMaybe($handler -> {
unwatch($handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI wait(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.wait(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI wait(String arg0, String arg1) {
return
wait(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxWait(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
wait(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI watch(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.watch(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI watch(List<String> args) {
return
watch(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxWatch(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
watch(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xack(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xack(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xack(List<String> args) {
return
xack(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXack(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xack(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xadd(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xadd(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xadd(List<String> args) {
return
xadd(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXadd(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xadd(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xclaim(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xclaim(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xclaim(List<String> args) {
return
xclaim(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXclaim(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xclaim(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xdel(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xdel(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xdel(List<String> args) {
return
xdel(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXdel(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xdel(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xgroup(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xgroup(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xgroup(List<String> args) {
return
xgroup(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXgroup(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xgroup(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xinfo(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xinfo(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xinfo(List<String> args) {
return
xinfo(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXinfo(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xinfo(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xlen(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xlen(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xlen(String arg0) {
return
xlen(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXlen(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
xlen(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xpending(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xpending(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xpending(List<String> args) {
return
xpending(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXpending(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xpending(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xrange(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xrange(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xrange(List<String> args) {
return
xrange(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXrange(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xrange(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xread(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xread(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xread(List<String> args) {
return
xread(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXread(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xread(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xreadgroup(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xreadgroup(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xreadgroup(List<String> args) {
return
xreadgroup(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXreadgroup(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xreadgroup(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xrevrange(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xrevrange(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xrevrange(List<String> args) {
return
xrevrange(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXrevrange(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xrevrange(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xsetid(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xsetid(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xsetid(String arg0, String arg1) {
return
xsetid(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXsetid(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
xsetid(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI xtrim(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.xtrim(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI xtrim(List<String> args) {
return
xtrim(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxXtrim(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
xtrim(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zadd(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zadd(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zadd(List<String> args) {
return
zadd(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZadd(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zadd(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zcard(String arg0, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zcard(arg0, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zcard(String arg0) {
return
zcard(arg0, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZcard(String arg0) {
return AsyncResultMaybe.toMaybe($handler -> {
zcard(arg0, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zcount(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zcount(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zcount(String arg0, String arg1, String arg2) {
return
zcount(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZcount(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
zcount(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zincrby(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zincrby(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zincrby(String arg0, String arg1, String arg2) {
return
zincrby(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZincrby(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
zincrby(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zinterstore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zinterstore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zinterstore(List<String> args) {
return
zinterstore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZinterstore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zinterstore(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zlexcount(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zlexcount(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zlexcount(String arg0, String arg1, String arg2) {
return
zlexcount(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZlexcount(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
zlexcount(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zpopmax(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zpopmax(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zpopmax(List<String> args) {
return
zpopmax(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZpopmax(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zpopmax(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zpopmin(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zpopmin(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zpopmin(List<String> args) {
return
zpopmin(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZpopmin(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zpopmin(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrange(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrange(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrange(List<String> args) {
return
zrange(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrange(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zrange(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrangebylex(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrangebylex(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrangebylex(List<String> args) {
return
zrangebylex(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrangebylex(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zrangebylex(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrangebyscore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrangebyscore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrangebyscore(List<String> args) {
return
zrangebyscore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrangebyscore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zrangebyscore(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrank(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrank(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrank(String arg0, String arg1) {
return
zrank(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrank(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
zrank(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrem(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrem(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrem(List<String> args) {
return
zrem(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrem(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zrem(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zremrangebylex(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zremrangebylex(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zremrangebylex(String arg0, String arg1, String arg2) {
return
zremrangebylex(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZremrangebylex(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
zremrangebylex(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zremrangebyrank(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zremrangebyrank(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zremrangebyrank(String arg0, String arg1, String arg2) {
return
zremrangebyrank(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZremrangebyrank(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
zremrangebyrank(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zremrangebyscore(String arg0, String arg1, String arg2, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zremrangebyscore(arg0, arg1, arg2, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zremrangebyscore(String arg0, String arg1, String arg2) {
return
zremrangebyscore(arg0, arg1, arg2, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZremrangebyscore(String arg0, String arg1, String arg2) {
return AsyncResultMaybe.toMaybe($handler -> {
zremrangebyscore(arg0, arg1, arg2, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrange(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrevrange(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrange(List<String> args) {
return
zrevrange(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrevrange(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zrevrange(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrangebylex(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrevrangebylex(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrangebylex(List<String> args) {
return
zrevrangebylex(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrevrangebylex(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zrevrangebylex(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrangebyscore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrevrangebyscore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrangebyscore(List<String> args) {
return
zrevrangebyscore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrevrangebyscore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zrevrangebyscore(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrank(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zrevrank(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zrevrank(String arg0, String arg1) {
return
zrevrank(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZrevrank(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
zrevrank(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zscan(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zscan(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zscan(List<String> args) {
return
zscan(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZscan(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zscan(args, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zscore(String arg0, String arg1, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zscore(arg0, arg1, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zscore(String arg0, String arg1) {
return
zscore(arg0, arg1, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZscore(String arg0, String arg1) {
return AsyncResultMaybe.toMaybe($handler -> {
zscore(arg0, arg1, $handler);
});
}
public io.vertx.reactivex.redis.client.RedisAPI zunionstore(List<String> args, Handler<AsyncResult<io.vertx.reactivex.redis.client.Response>> handler) {
delegate.zunionstore(args, new Handler<AsyncResult<io.vertx.redis.client.Response>>() {
public void handle(AsyncResult<io.vertx.redis.client.Response> ar) {
if (ar.succeeded()) {
handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.reactivex.redis.client.Response.newInstance((io.vertx.redis.client.Response)ar.result())));
} else {
handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
}
}
});
return this;
}
public io.vertx.reactivex.redis.client.RedisAPI zunionstore(List<String> args) {
return
zunionstore(args, ar -> { });
}
public io.reactivex.Maybe<io.vertx.reactivex.redis.client.Response> rxZunionstore(List<String> args) {
return AsyncResultMaybe.toMaybe($handler -> {
zunionstore(args, $handler);
});
}
public static io.vertx.reactivex.redis.client.RedisAPI api(io.vertx.reactivex.redis.client.Redis client) {
io.vertx.reactivex.redis.client.RedisAPI ret = io.vertx.reactivex.redis.client.RedisAPI.newInstance((io.vertx.redis.client.RedisAPI)io.vertx.redis.client.RedisAPI.api(client.getDelegate()));
return ret;
}
public static io.vertx.reactivex.redis.client.RedisAPI api(io.vertx.reactivex.redis.client.RedisConnection connection) {
io.vertx.reactivex.redis.client.RedisAPI ret = io.vertx.reactivex.redis.client.RedisAPI.newInstance((io.vertx.redis.client.RedisAPI)io.vertx.redis.client.RedisAPI.api(connection.getDelegate()));
return ret;
}
public static RedisAPI newInstance(io.vertx.redis.client.RedisAPI arg) {
return arg != null ? new RedisAPI(arg) : null;
}
}