Address feedback

Author: marcusdacoregio

spring-session-data-mongodb/src/main/java/org/springframework/session/data/mongo/ReactiveMongoSessionRepository.java

@@ -22,6 +22,7 @@
 import org.apache.commons.logging.LogFactory;
 import org.bson.Document;
 import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.context.ApplicationEvent;
@@ -97,12 +98,17 @@ public ReactiveMongoSessionRepository(ReactiveMongoOperations mongoOperations) {
 	 */
 	@Override
 	public Mono<MongoSession> createSession() {
-		return Mono.defer(() -> Mono.just(this.sessionIdGenerationStrategy.generate()))
-				.map((sessionId) -> new MongoSession(sessionId, this.defaultMaxInactiveInterval.toSeconds()))
+		// @formatter:off
+		return Mono.fromSupplier(() -> this.sessionIdGenerationStrategy.generate())
+				.map(MongoSession::new)
+				.doOnNext((mongoSession) -> mongoSession.setMaxInactiveInterval(this.defaultMaxInactiveInterval))
 				.doOnNext(
 						(mongoSession) -> mongoSession.setSessionIdGenerationStrategy(this.sessionIdGenerationStrategy))
 				.doOnNext((mongoSession) -> publishEvent(new SessionCreatedEvent(this, mongoSession)))
-				.switchIfEmpty(Mono.just(new MongoSession(this.sessionIdGenerationStrategy)));
+				.switchIfEmpty(Mono.just(new MongoSession(this.sessionIdGenerationStrategy)))
+				.subscribeOn(Schedulers.boundedElastic())
+				.publishOn(Schedulers.parallel());
+		// @formatter:on
 	}
 
 	@Override