Handle deleteBy properly to avoid NullPointerException.

gregturn · gregturn · commit e2198e36ea43 · 2019-09-06T12:28:05.000-05:00
Resolves #97.
diff --git 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 Mono<Void> deleteById(String id) {
 				.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();
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -136,7 +136,7 @@ public Mono<Void> deleteById(String id) {`
`136`	`136`	`.flatMap(document -> this.mongoOperations.remove(document, this.collectionName) //`
`137`	`137`	`.then(Mono.just(document))) //`
`138`	`138`	`.map(document -> convertToSession(this.mongoSessionConverter, document)) //`
`139`		`- .doOnSuccess(mongoSession -> publishEvent(new SessionDeletedEvent(this, mongoSession))) //`
	`139`	`+ .doOnNext(mongoSession -> publishEvent(new SessionDeletedEvent(this, mongoSession))) //`
`140`	`140`	`.then();`
`141`	`141`	`}`
`142`	`142`