From 45ae68b930db13ef2160d4f540a33a57f0cc9fcf Mon Sep 17 00:00:00 2001
From: ydvorzhetskiy <ydvorzhetskiy@navicons.ru>
Date: Sat, 26 Oct 2019 12:30:33 +0300
Subject: [PATCH] A bit of Fix

---
 .../src/main/java/ru/otus/spring/Main.java                     | 2 +-
 .../main/java/ru/otus/spring/repostory/PersonRepository.java   | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/Main.java b/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/Main.java
index 0a31d9ce..6ad1b997 100644
--- a/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/Main.java
+++ b/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/Main.java
@@ -30,7 +30,7 @@ public class Main {
         Disposable flux = repository.findAll()
                 .subscribe(p -> System.out.println(p.getName()));
 
-        Thread.sleep(5000);
+        Thread.sleep(20000);
 
         flux.dispose();
     }
diff --git a/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/repostory/PersonRepository.java b/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/repostory/PersonRepository.java
index 6ab4812c..0485aa38 100644
--- a/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/repostory/PersonRepository.java
+++ b/2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/repostory/PersonRepository.java
@@ -1,13 +1,14 @@
 package ru.otus.spring.repostory;
 
 import org.springframework.data.mongodb.repository.Query;
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
 import org.springframework.data.repository.reactive.ReactiveCrudRepository;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import ru.otus.spring.domain.Person;
 
 
-public interface PersonRepository extends ReactiveCrudRepository<Person, String> {
+public interface PersonRepository extends ReactiveMongoRepository<Person, String> {
 
     Flux<Person> findByName(String name);