From e2198e36ea43859b6a0a52ac0996e3af707aa78d Mon Sep 17 00:00:00 2001 From: Greg Turnquist Date: Fri, 6 Sep 2019 12:28:05 -0500 Subject: [PATCH] Handle deleteBy properly to avoid NullPointerException. Resolves #97. --- .../data/mongo/ReactiveMongoOperationsSessionRepository.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/session/data/mongo/ReactiveMongoOperationsSessionRepository.java b/src/main/java/org/springframework/session/data/mongo/ReactiveMongoOperationsSessionRepository.java index b38c282..779dd75 100644 --- a/src/main/java/org/springframework/session/data/mongo/ReactiveMongoOperationsSessionRepository.java +++ b/src/main/java/org/springframework/session/data/mongo/ReactiveMongoOperationsSessionRepository.java @@ -136,7 +136,7 @@ public class ReactiveMongoOperationsSessionRepository .flatMap(document -> this.mongoOperations.remove(document, this.collectionName) // .then(Mono.just(document))) // .map(document -> convertToSession(this.mongoSessionConverter, document)) // - .doOnSuccess(mongoSession -> publishEvent(new SessionDeletedEvent(this, mongoSession))) // + .doOnNext(mongoSession -> publishEvent(new SessionDeletedEvent(this, mongoSession))) // .then(); }