TA贡献1820条经验 获得超3个赞
或者take(1),如果您需要一个Mono<T>表示Flux<T>您可以使用的第一个元素的.next().
take(1)
Mono<T>
Flux<T>
.next()
或者,如果您需要第 i 个元素,请使用.elementAt(i)(但必须确保存在这样的元素,与如果没有足够的元素take,next它只会返回一个空的发布者不同)。
.elementAt(i)
take
next
TA贡献1934条经验 获得超2个赞
Flux.range(1,10).take(1)应该做的伎俩(range(...)这里的部分只是发出一些样本值;如果你blockFirst()或subscribe()流,你应该看到'1')
Flux.range(1,10).take(1)
range(...)
blockFirst()
subscribe()
大厂算法面试真题解析32讲
¥ 68.00
32 堂微服务架构设计与落地精讲课
¥ 78.00
Java 并发编程深度解析
¥ 58.00
网络编程之Netty一站式精讲
再学经典:《Effective Java》独家解析
举报
购课补贴联系客服咨询优惠详情
慕课网APP您的移动学习伙伴
扫描二维码关注慕课网微信公众号