<filename>src/main/java/com/auto/applet/demo/dao/MyEventRepository.java
package com.auto.applet.demo.dao;

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

import com.auto.applet.demo.model.MyEvent;

import reactor.core.publisher.Flux;

/**
 * 下边用到了可以保存Flux的insert(Flux)方法，这个方法是在ReactiveMongoRepository中定义的
 * @author li_xiaodong
 * @date 2018年6月1日
 */
public interface MyEventRepository extends ReactiveMongoRepository<MyEvent, Long> {
	
	 /**
	  * 1/@Tailable注解的作用类似于linux的tail命令，被注解的方法将发送无限流，需要注解在返回值为Flux这样的多个元素的Publisher的方法上；
2/findAll()是想要的方法，但是在ReactiveMongoRepository中我们够不着，所以使用findBy()代替。
	 * @return
	 */
	@Tailable   // 1
     Flux<MyEvent> findBy(); // 2

}
