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

Exceptions.errorCallbackNotImplemented介绍

[英]Return an UnsupportedOperationException indicating that the error callback on a subscriber was not implemented, yet an error was propagated.
[中]返回UnsupportedOperationException，指示订阅服务器上的错误回调未实现，但已传播错误。

代码示例

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

/**
 * Optional hook for error processing. Default is to call
 * {@link Exceptions#errorCallbackNotImplemented(Throwable)}.
 *
 * @param throwable the error to process
 */
protected void hookOnError(Throwable throwable) {
  throw Exceptions.errorCallbackNotImplemented(throwable);
}

代码示例来源：origin: resilience4j/resilience4j

/**
 * Optional hook for error processing. Default is to call
 * {@link Exceptions#errorCallbackNotImplemented(Throwable)}.
 *
 * @param throwable the error to process
 */
protected void hookOnError(Throwable throwable) {
  throw Exceptions.errorCallbackNotImplemented(throwable);
}

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

void doError(Throwable t) {
  if (errorConsumer != null) {
    errorConsumer.accept(t);
  }
  else {
    throw Exceptions.errorCallbackNotImplemented(t);
  }
}

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

@Override
public void onError(Throwable t) {
  Operators.onErrorDropped(Exceptions.errorCallbackNotImplemented(t), Context.empty());
}

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

@Override
public final void onError(Throwable t) {
  Subscription s = S.getAndSet(this, Operators.cancelledSubscription());
  if (s == Operators.cancelledSubscription()) {
    Operators.onErrorDropped(t, Context.empty());
    return;
  }
  if (errorConsumer != null) {
    errorConsumer.accept(t);
  }
  else {
    throw Exceptions.errorCallbackNotImplemented(t);
  }
}

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

@Test
public void testUncaughtHookCalledWhenOnErrorNotImplemented() {
  AtomicBoolean handled = new AtomicBoolean(false);
  Schedulers.onHandleError((t, e) -> handled.set(true));
  try {
    Schedulers.handleError(Exceptions.errorCallbackNotImplemented(new IllegalArgumentException()));
  } finally {
    Schedulers.resetOnHandleError();
  }
  Assert.assertTrue("errorCallbackNotImplemented not handled", handled.get());
}

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

})
        .doOnError(s -> {
          throw Exceptions.errorCallbackNotImplemented(new Exception(
              "unsupported"));
        })).fusionMode(Fuseable.NONE)
}, null, null)
         .doOnError(s -> {
           throw Exceptions.errorCallbackNotImplemented(new Exception(
               "unsupported"));
         })).verifier(step -> {
}, null, null)
         .doOnError(s -> {
           throw Exceptions.errorCallbackNotImplemented(s);
         })).verifier(step -> {
  try {

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

/**
 * Optional hook for error processing. Default is to call
 * {@link Exceptions#errorCallbackNotImplemented(Throwable)}.
 *
 * @param throwable the error to process
 */
protected void hookOnError(Throwable throwable) {
  throw Exceptions.errorCallbackNotImplemented(throwable);
}

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

void doError(Throwable t) {
  if (errorConsumer != null) {
    errorConsumer.accept(t);
  }
  else {
    throw Exceptions.errorCallbackNotImplemented(t);
  }
}

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

@Override
public void onError(Throwable t) {
  Operators.onErrorDropped(Exceptions.errorCallbackNotImplemented(t), Context.empty());
}

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

@Override
public final void onError(Throwable t) {
  Subscription s = S.getAndSet(this, Operators.cancelledSubscription());
  if (s == Operators.cancelledSubscription()) {
    Operators.onErrorDropped(t, Context.empty());
    return;
  }
  if (errorConsumer != null) {
    errorConsumer.accept(t);
  }
  else {
    throw Exceptions.errorCallbackNotImplemented(t);
  }
}