Handle deleteBy properly to avoid NullPointerException.

Resolves #97.
This commit is contained in:
Greg Turnquist
2019-09-06 12:28:05 -05:00
parent 318963a08b
commit e2198e36ea

View File

@@ -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();
}