我可以将 Publisher 的结果传递给 Reactor Context 吗？

【问题标题】：Can I pass the result of a Publisher down to a Reactor Context?我可以将 Publisher 的结果传递给 Reactor Context 吗？
【发布时间】：2021-04-25 21:59:29
【问题描述】：

我有一个来自发布者的io.grpc.Context。我可以将 write 传递到 Reactor Context 中吗？

Mono.just(io.grpc.Context.current())
  .contextWrite(grpcContext -> 
    reactor.util.context.Context.of(MY_KEY, grpcContext))

这样的事情可能吗？原因是因为我有一个 OnNextOperator 钩子，我想在 grpc.Context 中监听这个变化

【问题讨论】：

标签： java grpc project-reactor

【解决方案1】：

这样的事情可能吗？

如果您想在下游访问上下文，则不是 - 上下文注入是 subscription 信号的一部分，该信号从下到上向上游流动。这与其他从上到下向下游流动的反应信号（next、error）形成鲜明对比。

如果您想在下游读取这样的值，唯一明智的选择是将其作为元素本身的一部分包含在内 - 通常使用zip()、zipWith() 或类似方法。

【讨论】：