问题方法需要等待单声道操作结果,在通量操作中使用,并返回通量。
public Flux<My> getMy() {
Mono<ZonedDateTime> dateTimeMono = getDateTime();
Flux<My> mies = reactiveMongoTemplate.find(
new Query(Criteria.where("dateTime").gt(dateTimeMono)),
My.class,
collectionName);
return mies;
}
研究我希望dateTimeMono
流被Mongo反应驱动订阅并终止,所以我不订阅。如果我使用Mono。zip
我有单声道
任务如何等待dateTimeMono
值,在通量操作中使用它并从中获取通量?
你应该使用flaMap很多:
public Flux<My> getMy() {
return getDateTime().flatMapMany(date -> reactiveMongoTemplate.find(new Query(Criteria.where("dateTime").gt(date)),My.class,collectionName));
}