From c32cedb97bad55cb10362ad5f77b0dbbc02bdc83 Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@pivotal.io>
Date: Wed, 25 Oct 2017 11:39:42 +0200
Subject: [PATCH] #312 - Adapt reactive MongoDB example readme to changed
 @Tailable annotation.
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Adapt also changed insertAll(…) signature to accept a Collection instead of a Flux.
---
 mongodb/reactive/README.md | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/mongodb/reactive/README.md b/mongodb/reactive/README.md
index 17d6b3ed..6ca4b81e 100644
--- a/mongodb/reactive/README.md
+++ b/mongodb/reactive/README.md
@@ -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.
 
 ```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("Saul", "Goodman", 42),
 				new Person("Jesse", "Pinkman", 27)));
@@ -42,7 +42,7 @@ public interface ReactivePersonRepository extends ReactiveCrudRepository<Person,
 
 	Mono<Person> findByFirstnameAndLastname(Mono<String> firstname, String lastname);
 
-	@InfiniteStream // Use a tailable cursor
+	@Tailable // Use a tailable cursor
 	Flux<Person> findWithTailableCursorBy();
 }
 ```
@@ -60,7 +60,7 @@ public interface RxJava2PersonRepository extends RxJava2CrudRepository<Person, S
 
 	Maybe<Person> findByFirstnameAndLastname(Single<String> firstname, String lastname);
 
-	@InfiniteStream // Use a tailable cursor
+	@Tailable // Use a tailable cursor
 	Flowable<Person> findWithTailableCursorBy();
 }
 ```