Redis reads session once not twice during cleanup

I noticed that the session gets read twice at https://github.com/spring-projects/spring-session/blob/4dc81ec10d0e2870bb6f208df924b2ab933a835e/spring-session-data-redis/src/main/java/org/springframework/session/data/redis/ReactiveRedisIndexedSessionRepository.java#L441-L442. This alters the code to only read it once.

Author: kinsersh

spring-session-data-redis/src/main/java/org/springframework/session/data/redis/ReactiveRedisIndexedSessionRepository.java

@@ -385,13 +385,17 @@ private Mono<RedisSession> getSession(String sessionId, boolean allowExpired) {
 
 	@Override
 	public Mono<Void> deleteById(String id) {
+		return internalDeleteById(id).then();
+	}
+
+	public Mono<Session> internalDeleteById(String id) {
 		// @formatter:off
 		return getSession(id, true)
 				.flatMap((session) -> this.sessionRedisOperations.delete(getExpiredKey(session.getId()))
 						.thenReturn(session))
 				.flatMap((session) -> this.sessionRedisOperations.delete(getSessionKey(session.getId())).thenReturn(session))
 				.flatMap((session) -> this.indexer.delete(session.getId()).thenReturn(session))
-				.flatMap((session) -> this.expirationStore.remove(session.getId()));
+				.flatMap((session) -> this.expirationStore.remove(session.getId()).thenReturn(session));
 		// @formatter:on
 	}
 
@@ -438,8 +442,7 @@ private Mono<Void> onKeyDestroyedMessage(ReactiveSubscription.Message<String, St
 			int sessionIdBeginIndex = key.lastIndexOf(":") + 1;
 			return key.substring(sessionIdBeginIndex);
 		})
-			.flatMap((sessionId) -> getSession(sessionId, true))
-			.flatMap((session) -> this.deleteById(session.getId()).thenReturn(session))
+			.flatMap(this::internalDeleteById)
 			.map((session) -> {
 				if (message.getChannel().equals(this.sessionDeletedChannel)) {
 					return new SessionDeletedEvent(this, session);