WebFlux 意外行为 - 编程之家

如何解决WebFlux 意外行为

我必须进行一些 API 调用，进行一些处理并合并结果。这是示例代码：

package com.example.demo;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@RestController
@RequestMapping("/orders")
public class OrderController {
    @GetMapping("/{id}")
    private Mono<String> getordersById(@PathVariable String id) {
        Mono<String> order = Mono.just("Order 1");
        Flux<Integer> items = Flux.just(1,2,3,4);
        Mono<String> sum = items.reduce((accu,next) -> accu + next).map(s -> s.toString());
        Mono<String> fullOrder = order.zipwith(sum,(o,i) -> o + ",value: " + sum);
        return fullOrder;
    }
}

我认为对于这样的合并，好的工具是 zip 方法，但结果是： 顺序 1，值：MonoMapFuseable 这是为什么？是否有另一种从其他 Monos 合并的返回 Mono 的正确方法？项目由 Spring Initializr 生成，具有 Spring Reactive Web 依赖项。