Spring/spring-data-examples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#312 - Adapt reactive MongoDB example readme to changed @Tailable annotation.

Browse Source 
Adapt also changed insertAll(…) signature to accept a Collection instead of a Flux.
This commit is contained in:
Mark Paluch
2017-10-25 11:39:42 +02:00
parent 7bad34a7de
commit c32cedb97b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
mongodb/reactive/README.md
View File

@@ -13,7 +13,7 @@ together with blocking Spring Data MongoDB data access will open multiple connec
The main reactive Template API class is `ReactiveMongoTemplate`, ideally used through its interface `ReactiveMongoOperations`. It defines a basic set of reactive data access operations using [Project Reactor](http://projectreactor.io) `Mono` and `Flux` reactive types. The main reactive Template API class is `ReactiveMongoTemplate`, ideally used through its interface `ReactiveMongoOperations`. It defines a basic set of reactive data access operations using [Project Reactor](http://projectreactor.io) `Mono` and `Flux` reactive types.
```java ```java
template.insertAll(Flux.just(new Person("Walter", "White", 50), template.insertAll(Arrays.asList(new Person("Walter", "White", 50),
new Person("Skyler", "White", 45), new Person("Skyler", "White", 45),
new Person("Saul", "Goodman", 42), new Person("Saul", "Goodman", 42),
new Person("Jesse", "Pinkman", 27))); new Person("Jesse", "Pinkman", 27)));
@@ -42,7 +42,7 @@ public interface ReactivePersonRepository extends ReactiveCrudRepository<Person,
Mono<Person> findByFirstnameAndLastname(Mono<String> firstname, String lastname); Mono<Person> findByFirstnameAndLastname(Mono<String> firstname, String lastname);
@InfiniteStream // Use a tailable cursor @Tailable // Use a tailable cursor
Flux<Person> findWithTailableCursorBy(); Flux<Person> findWithTailableCursorBy();
} }
``` ```
@@ -60,7 +60,7 @@ public interface RxJava2PersonRepository extends RxJava2CrudRepository<Person, S
Maybe<Person> findByFirstnameAndLastname(Single<String> firstname, String lastname); Maybe<Person> findByFirstnameAndLastname(Single<String> firstname, String lastname);
@InfiniteStream // Use a tailable cursor @Tailable // Use a tailable cursor
Flowable<Person> findWithTailableCursorBy(); Flowable<Person> findWithTailableCursorBy();
} }
``` ```