问题:方法需要等待Mono操作结果,将其用于Flux操作并返回Flux。
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;
}
研究
我希望Mongo reactive driver会订阅并终止dateTimeMono
流,所以我不需要自己进行订阅。如果我使用Mono.zip
,将会得到Mono<Flux>作为返回类型。
任务
如何等待dateTimeMono
的值,将其用于Flux操作并从中获取Flux?
flatMapMany
可以解决问题。非常感谢。你不想发表一个答案吗? - Zon