为了账号安全,请及时绑定邮箱和手机立即绑定

当 Flux 完成时获取 Flux 大小

当 Flux 完成时获取 Flux 大小

千巷猫影 2021-06-10 17:48:36
我有点忙于一项微不足道的任务:每当我使用反应式 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:如何在完成时获得通量大小(也许是内容)?
查看完整描述

3 回答

?
qq_笑_17

TA贡献1818条经验 获得超7个赞

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


查看完整回答
反对 回复 2021-06-23
  • 3 回答
  • 0 关注
  • 320 浏览

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信