package de.springbootbuch.reactive.watchednow;

import org.springframework.data.mongodb.repository.ReactiveMongoRepository;

/**
 * Part of springbootbuch.de.
 * 
 * @author Michael J. Simons
 * @author @rotnroll666
 */
public interface FilmWatchedEventRepository 
	extends ReactiveMongoRepository<FilmWatchedEvent, String> {
}

@@ -92,24 +92,86 @@
 ository.
+Tailable;%0Aimport org.springframework.data.repository.reactive.
 Reactive
 MongoRep
@@ -154,37 +154,36 @@
 eactive.Reactive
-Mongo
+Crud
 Repository;%0A%0A/**
@@ -177,16 +177,52 @@
 ository;
+%0Aimport reactor.core.publisher.Flux;
 %0A%0A/**%0A *
@@ -376,13 +376,12 @@
 tive
-Mongo
+Crud
 Repo
@@ -415,10 +415,62 @@
 ring%3E %7B%0A
+%09%0A%09@Tailable%0A%09Flux%3CFilmWatchedEvent%3E streamAllBy();%0A
 %7D%0A

Introduce @Tailable