github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #4547 from zhuangzibin/fix/setIfAbsent

Browse Source 
fix: setIfAbsent empty
pull/4551/head
Nikita Koksharov 3 years ago committed by GitHub
parent bacd89756d 5b887b42d0
commit 4e078a1a5a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
8 changed files with 88 additions and 119 deletions
Show Stats Download Patch File Download Diff File

26
redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,34 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

26
redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,34 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

26
redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,34 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

26
redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,34 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

26
redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,34 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

26
redisson-spring-data/redisson-spring-data-25/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,34 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

26
redisson-spring-data/redisson-spring-data-26/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,34 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

25
redisson-spring-data/redisson-spring-data-27/src/main/java/org/redisson/spring/data/connection/RedissonReactiveStringCommands.java
Unescape Escape View File

@ -70,38 +70,35 @@ public class RedissonReactiveStringCommands extends RedissonBaseReactive impleme
byte[] key = toByteArray(command.getKey());
byte[] value = toByteArray(command.getValue());
Mono<Boolean> m = Mono.empty();
if (!command.getExpiration().isPresent()) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
} else if (command.getExpiration().get().isPersistent()) {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value);
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value);
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "XX");
}
} else {
if (!command.getOption().isPresent() || command.getOption().get() == SetOption.UPSERT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds());
}
if (command.getOption().get() == SetOption.SET_IF_ABSENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
return m.map(v -> new BooleanResponse<>(command, v));
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "NX");
}
if (command.getOption().get() == SetOption.SET_IF_PRESENT) {
Mono<Boolean> m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
m = write(key, StringCodec.INSTANCE, SET, key, value, "PX", command.getExpiration().get().getExpirationTimeInMilliseconds(), "XX");
return m.map(v -> new BooleanResponse<>(command, v));
}
}
throw new IllegalArgumentException();
return m.map(v -> new BooleanResponse<>(command, v))
.switchIfEmpty(Mono.just(new BooleanResponse<>(command, Boolean.FALSE)));
});
}

Write Preview
Loading…
Cancel
Save