reactor.core.publisher.Hooks.createOrUpdateOpHook()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(256)

本文整理了Java中reactor.core.publisher.Hooks.createOrUpdateOpHook()方法的一些代码示例,展示了Hooks.createOrUpdateOpHook()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Hooks.createOrUpdateOpHook()方法的具体详情如下:
包路径:reactor.core.publisher.Hooks
类名称:Hooks
方法名:createOrUpdateOpHook

Hooks.createOrUpdateOpHook介绍

暂无

代码示例

代码示例来源:origin: reactor/reactor-core

  1. /**
  2. * Remove the sub-hook with key {@code key} from the onEachOperator hook. No-op if
  3. * no such key has been registered, and equivalent to calling {@link #resetOnEachOperator()}
  4. * if it was the last sub-hook.
  5. *
  6. * @param key the key of the sub-hook to remove
  7. */
  8. public static void resetOnEachOperator(String key) {
  9. Objects.requireNonNull(key, "key");
  10. log.debug("Reset onEachOperator: {}", key);
  11. synchronized (log) {
  12. onEachOperatorHooks.remove(key);
  13. onEachOperatorHook = createOrUpdateOpHook(onEachOperatorHooks.values());
  14. }
  15. }

代码示例来源:origin: reactor/reactor-core

  1. /**
  2. * Remove the sub-hook with key {@code key} from the onLastOperator hook. No-op if
  3. * no such key has been registered, and equivalent to calling {@link #resetOnLastOperator()}
  4. * if it was the last sub-hook.
  5. *
  6. * @param key the key of the sub-hook to remove
  7. */
  8. public static void resetOnLastOperator(String key) {
  9. Objects.requireNonNull(key, "key");
  10. log.debug("Reset onLastOperator: {}", key);
  11. synchronized (log) {
  12. onLastOperatorHooks.remove(key);
  13. onLastOperatorHook = createOrUpdateOpHook(onLastOperatorHooks.values());
  14. }
  15. }

代码示例来源:origin: reactor/reactor-core

  1. onLastOperatorHook = createOrUpdateOpHook(onLastOperatorHooks.values());

代码示例来源:origin: reactor/reactor-core

  1. onEachOperatorHook = createOrUpdateOpHook(onEachOperatorHooks.values());

代码示例来源:origin: io.projectreactor/reactor-core

  1. /**
  2. * Remove the sub-hook with key {@code key} from the onLastOperator hook. No-op if
  3. * no such key has been registered, and equivalent to calling {@link #resetOnLastOperator()}
  4. * if it was the last sub-hook.
  5. *
  6. * @param key the key of the sub-hook to remove
  7. */
  8. public static void resetOnLastOperator(String key) {
  9. Objects.requireNonNull(key, "key");
  10. log.debug("Reset onLastOperator: {}", key);
  11. synchronized (log) {
  12. onLastOperatorHooks.remove(key);
  13. onLastOperatorHook = createOrUpdateOpHook(onLastOperatorHooks.values());
  14. }
  15. }

代码示例来源:origin: io.projectreactor/reactor-core

  1. /**
  2. * Remove the sub-hook with key {@code key} from the onEachOperator hook. No-op if
  3. * no such key has been registered, and equivalent to calling {@link #resetOnEachOperator()}
  4. * if it was the last sub-hook.
  5. *
  6. * @param key the key of the sub-hook to remove
  7. */
  8. public static void resetOnEachOperator(String key) {
  9. Objects.requireNonNull(key, "key");
  10. log.debug("Reset onEachOperator: {}", key);
  11. synchronized (log) {
  12. onEachOperatorHooks.remove(key);
  13. onEachOperatorHook = createOrUpdateOpHook(onEachOperatorHooks.values());
  14. }
  15. }

代码示例来源:origin: io.projectreactor/reactor-core

  1. onLastOperatorHook = createOrUpdateOpHook(onLastOperatorHooks.values());

代码示例来源:origin: io.projectreactor/reactor-core

  1. onEachOperatorHook = createOrUpdateOpHook(onEachOperatorHooks.values());

相关文章