diff --git a/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/ReactiveRedisOperationsSessionRepository.java b/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/ReactiveRedisOperationsSessionRepository.java index 4c640571..b415f12b 100644 --- a/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/ReactiveRedisOperationsSessionRepository.java +++ b/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/ReactiveRedisOperationsSessionRepository.java @@ -143,7 +143,8 @@ public class ReactiveRedisOperationsSessionRepository implements @Override public Mono save(RedisSession session) { - Mono result = session.saveChangeSessionId().and(session.saveDelta()) + Mono result = session.saveChangeSessionId() + .then(session.saveDelta()) .and((s) -> { session.isNew = false; s.onComplete();