package de.springbootbuch.reactive.watchednow;

import org.springframework.data.mongodb.repository.Tailable;
import org.springframework.data.repository.reactive.ReactiveCrudRepository;
import reactor.core.publisher.Flux;

/**
 * Part of springbootbuch.de.
 * 
 * @author Michael J. Simons
 * @author @rotnroll666
 */
public interface FilmWatchedEventRepository  extends 
	ReactiveCrudRepository<FilmWatchedEvent, String> {
	
	@Tailable
	Flux<FilmWatchedEvent> streamAllBy();
}

@@ -149,29 +149,8 @@
 ory.
-reactive.ReactiveCrud
 Repo
@@ -157,16 +157,16 @@
 sitory;%0A
+
 import r
@@ -192,16 +192,52 @@
 er.Flux;
+%0Aimport reactor.core.publisher.Mono;
 %0A%0A/**%0A *
@@ -384,20 +384,8 @@
 s %0A%09
-ReactiveCrud
 Repo
@@ -421,16 +421,72 @@
 ng%3E %7B%0A%09%0A
+%09Mono%3CFilmWatchedEvent%3E save(FilmWatchedEvent event);%0A%09%0A
 %09@Tailab

Use simpler repository interface