如何解决为什么上下文不会从ReactorMono 传播到RxJavaSingle?
make_test([](int a,double b) { std::cout << a << b << "\n"; });
下游,我的控制器执行此操作
public Mono<Void> filter(ServerWebExchange exchange,WebFilterChain chain) {
return chain.filter(exchange)
.contextWrite(Context.of("my-context","foobar"));
}
以上一切正常。
如果我想从控制器方法返回一个 Single 怎么办?我尝试使用 @GetMapping(path = "test")
public Mono<String> test() throws Exception {
final Mono<ContextView> contextMono = Mono.deferContextual(Mono::just);
return contextMono.flatMap(ctx -> Mono.just(ctx.get("my-context")));
}
但它破坏了反应堆链。
RxJava3Adapter.monoToSingle()
我的猜测是,由于我没有返回 Mono,因此在 RxJava3Adapter 中没有任何内容订阅此 contextMono。这是正确的解释吗?
有没有办法在传入上下文的同时返回 Single ?
解决方法
订阅本身运行良好。问题是 Context
是 Reactor 特定的功能,它不是 Reactive Streams 标准的一部分。因此,当您将 Mono
转换为 Single
时,Context
会丢失。
在您附加的代码中,您应该简单地省略 Rx 部分以使其工作,但我想您的实际用例可能会更加复杂。一个好的方法是尽早将 Rx 代码转换为 Reactor(例如,当您调用返回 Rx 类型的第三方库时),并在代码库的其余部分(包括控制器返回类型)中使用 Reactor。>
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。