From 96b564eb9a572569804392ad6eb549d627a583dd Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Fri, 16 Sep 2022 14:40:22 +0200 Subject: [PATCH] Polishing. Reformat code. See #4167. Original pull request: #4168. --- .../data/mongodb/core/ReactiveMongoTemplate.java | 11 +++++++---- .../mongodb/core/ReactiveMongoTemplateUnitTests.java | 5 ++++- 2 files changed, 11 insertions(+), 5 deletions(-) diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReactiveMongoTemplate.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReactiveMongoTemplate.java index 9af3b5518..d867fb616 100644 --- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReactiveMongoTemplate.java +++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReactiveMongoTemplate.java @@ -663,7 +663,8 @@ public class ReactiveMongoTemplate implements ReactiveMongoOperations, Applicati } @Override - public Mono> createView(String name, Class source, AggregationPipeline pipeline, @Nullable ViewOptions options) { + public Mono> createView(String name, Class source, AggregationPipeline pipeline, + @Nullable ViewOptions options) { return createView(name, getCollectionName(source), queryOperations.createAggregation(Aggregation.newAggregation(source, pipeline.getOperations()), source), @@ -1894,10 +1895,12 @@ public class ReactiveMongoTemplate implements ReactiveMongoOperations, Applicati publisher = filter.isEmpty() ? db.watch(Document.class) : db.watch(filter, Document.class); } - if(options.isResumeAfter()) { - publisher = options.getResumeToken().map(BsonValue::asDocument).map(publisher::resumeAfter).orElse(publisher); + if (options.isResumeAfter()) { + publisher = options.getResumeToken().map(BsonValue::asDocument).map(publisher::resumeAfter) + .orElse(publisher); } else if (options.isStartAfter()) { - publisher = options.getResumeToken().map(BsonValue::asDocument).map(publisher::startAfter).orElse(publisher); + publisher = options.getResumeToken().map(BsonValue::asDocument).map(publisher::startAfter) + .orElse(publisher); } publisher = options.getCollation().map(Collation::toMongoCollation).map(publisher::collation) .orElse(publisher); diff --git a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateUnitTests.java b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateUnitTests.java index b6fedd86e..01e827751 100644 --- a/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateUnitTests.java +++ b/spring-data-mongodb/src/test/java/org/springframework/data/mongodb/core/ReactiveMongoTemplateUnitTests.java @@ -1500,7 +1500,9 @@ public class ReactiveMongoTemplateUnitTests { when(changeStreamPublisher.fullDocument(any())).thenReturn(changeStreamPublisher); BsonDocument token = new BsonDocument("token", new BsonString("id")); - template.changeStream("database", "collection", ChangeStreamOptions.builder().startAfter(token).build(), Object.class).subscribe(); + template + .changeStream("database", "collection", ChangeStreamOptions.builder().startAfter(token).build(), Object.class) + .subscribe(); verify(changeStreamPublisher).startAfter(eq(token)); } @@ -1530,6 +1532,7 @@ public class ReactiveMongoTemplateUnitTests { AutogenerateableId foo; } + static class PersonExtended extends Person { String lastname;