GitHub/Spring
1
0
Fork 0
mirror of https://github.com/OtusTeam/Spring.git synced 2026-05-30 10:50:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

A bit of Fix

Browse Source
This commit is contained in:
ydvorzhetskiy
2019-10-26 12:30:33 +03:00
parent 037bb154fe
commit 45ae68b930
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/Main.java
+1 -1
View File
@@ -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();
}
2019-08/spring-17/spring-17-reactive-spring-data/src/main/java/ru/otus/spring/repostory/PersonRepository.java
+2 -1
View File
@@ -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);