我有一个Web方法,该方法将在时间到时(将其链接到发布/订阅)返回一个通量对象。仅在第一次调用时,至少可以返回默认值吗?
public Flux<String> receiveStream() {
return myReactiveService.getData() //here can I return a value at start? //.map(...);
“仅对于第一个电话”做到这一点并不容易。除非您采取特定步骤进行更改,否则每个请求都应具有自己的字符串序列。这有两个层次: -WebFlux
:每个请求都导致对控制器方法的单独调用,因此Flux
是新实例化的 -Reactor
:大多数Flux
是“冷”的,即它们只有在订阅后才会生成数据,并且每个订阅都会重新生成一个单独的数据集。
我认为您正在寻找的是Flux#defaultIfEmpty