如何使用Sink-in-projectreactor定制subscribe（）行为？
对于流量，您可以指定订阅时发生的自定义操作。例如Flux。创建（发射器）-
对于接收器，我们如何进行这样的自定义订阅操作？例如，接收器。不安全（）。许多（）。单播（）。反向压力缓冲（某些动作）？
我已经设法使用Flux使其工作。concat（Mono.fromRunnable（someAction），sink），但我认为这会增加不必要的开销，因此并不理想。
共有1个答案
您可以使用doOnSubscribe操作符：
java prettyprint-override">sink.asFlux().doOnSubscribe(someAction)
-
vue3页面中如何使用wx-open-subscribe,我vue3移动端里面怎么调起微信公众号订阅功能
-
我开发了一个利用基于令牌的身份验证的无状态REST API，其中我通过调用从自定义安全过滤器内手动将Authentication对象添加到安全上下文。我一直遇到上下文未正确设置的问题，我相信这是由于： 在请求之间存储SecurityContext 在单个会话中接收并发请求的应用程序中，相同的SecurityContext实例将在线程之间共享。尽管正在使用ThreadLocal，但从HttpSess
-
SUBSCRIBE channel [channel ...] 订阅给定的一个或多个频道的信息。 可用版本： >= 2.0.0 时间复杂度： O(N)，其中 N 是订阅的频道的数量。 返回值： 接收到的信息(请参见下面的代码说明)。 # 订阅 msg 和 chat_room 两个频道 # 1 - 6 行是执行 subscribe 之后的反馈信息 # 第 7 - 9 行才是接收到的第一条信息 #
-
问题内容： Go对于此SQL查询中的第二个参数想要什么。我正在尝试在postgres中使用查找。 我真正想要的是： 问题答案： 查询只是使用varargs来替换sql中的参数，因此，在您的示例中，您只需要执行 例如，这个和第二个示例的内容是动态的，那么您将 如果“ IN”部分具有可变的args，则可以执行（播放）
-
我有一个用例，需要跟踪给定组件的处理时间指标，并将其用作spring boot应用程序中调优的反馈循环。我想我应该在需要监视的组件中通过一个自动连接的计量服务使用一个自定义指标，该服务工作正常，我可以在/指标endpoint中看到我的指标。我遇到的问题是如何在应用程序代码中使用这些指标。理想情况下，我希望收到每个仪表提交的结果，并计算加权移动平均值。对于spring boot执行器指标来说，这不是
-
我试图理解Flink中的并行是如何工作的。本文件https://ci.apache.org/projects/flink/flink-docs-release-1.9/concepts/programming-model.html似乎表明水槽的平行度等于1。在我的例子中，我正在向我的接收器中的HBase写信——这是否意味着只有一个任务（线程？）哪个将写入HBase？它是否没有为应用程序设置全局并行