当 Flux 完成时获取 Flux 大小

Question

我有点忙于一项微不足道的任务：每当我使用反应式 spring WebClient 查询外部 API 或查询反应式 MongoDBRepository 时，我想记录有多少实体通过了我的通量，例如。记录“在数据库中找到 n 条记录”之类的消息。例如：

return repository.findAll()

                 .doOnComplete { log.info("Found total n records!") } // how to get the n?

                 .filter { it.age > 10 }

                 .distinct { it.name }

TLDR：如何在完成时获得通量大小（也许是内容）？

Answer 1

通过调用count()。当观察到 onComplete 时，它应该发出 Mono。