当流量为空时返回404

Question

我试图在流量为空时返回404，类似于这里：WebFlux Functional：如何检测空流量并返回404？

我主要担心的是，当你检查通量是否有元素时，它会发出那个值，而你却松开了它。当我尝试使用switch时，如果服务器响应为空，它就永远不会被调用（我暗暗认为这是因为单声道不是空的，只有主体是空的）。

Flux<Location> response = this.locationService.searchLocations(searchFields, pageToken);
return ok()
        .contentType(APPLICATION_STREAM_JSON)
        .body(response, Location.class)
        .switchIfEmpty(Mono.error(new DataNotFoundException("The data you seek is not here.")));

Flux<Location> response = this.locationService.searchLocations(searchFields, pageToken);

return response.hasElements().flatMap(l ->{
   if(l){
       return ok()
               .contentType(APPLICATION_STREAM_JSON)
               .body(response, Location.class);
   } 
   else{
       return Mono.error(new DataNotFoundException("The data you seek is not here."));
   }
});

是否有一种方法可以恢复hasElements中发出的元素，或者让switchIfEmpty只检查主体的内容？

Answer 1

您可以将switchifempty运算符应用于flux 响应 。

Flux<Location> response = this.locationService
        .searchLocations(searchFields, pageToken)
        .switchIfEmpty(Mono.error(new DataNotFoundException("The data you seek is not here.")));