流返回错误的类型

Question

我试图理解反应性风格。但是在这个示例上陷入困境。

public class ScriptServiceImpl implements ScriptService{

    private static Logger log = LoggerFactory.getLogger(ScriptServiceImpl.class);
    private final ScriptEngineManager manager = new ScriptEngineManager();
    private final ScriptEngine engine = manager.getEngineByName("JavaScript");

    @Override
    public Flux<MyFunctionResult> evaluate(MyFunction myFunction, Integer iterations){
        Flux<MyFunctionResult> flux = Flux.empty();
        flux.mergeWith(
                Flux.range(1,iterations)
                .map(counter -> {
                    engine.put("parametr", counter);
                    try {
                        long start = System.currentTimeMillis();
                        String functionResult = engine.eval(myFunction.getSource()).toString();
                        long timer = System.currentTimeMillis() - start;

                        return Mono.just(new MyFunctionResult(timer, functionResult, myFunction.getNumber(), counter));
                    } catch (ScriptException ex) {
                        return Mono.error(ex);
                    }
                })
        );
        return flux;
    }
}

我想返回myFunctionResult的flux，但获取flux of object> object in in flux.mergewith部分。我在做什么错？

Answer 1

这里有多个问题，

• 您不需要将myFunctionResult纳入mono。 地图期望无反应的返回类型。结果，而不是mono.Error您应该将检查的异常包装到未检查的RuntimeTimeException中。
• 您需要返回flux.mergewith而不是flux的结果。但是通常，在此示例中，您不需要Mergewith

您的代码可以被转换为

return Flux.range(1,iterations)
        .map(counter -> {
            engine.put("parametr", counter);
            try {
                long start = System.currentTimeMillis();
                String functionResult = engine.eval(myFunction.getSource()).toString();
                long timer = System.currentTimeMillis() - start;

                return new MyFunctionResult(timer, functionResult, myFunction.getNumber(), counter);
            } catch (ScriptException ex) {
                throw Exceptions.propagate(ex);
            }
        });

另外，不确定Engine.eval.eval，但如果这是阻止代码它并在单独的调度程序上运行打电话？