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

Notification.createOnError介绍

[英]Creates and returns a Notification of variety Kind.OnError, and assigns it an exception.
[中]创建并返回各种类型的通知。OnError，并为其指定一个异常。

代码示例

代码示例来源：origin: PipelineAI/pipeline

@Override
public <T> Exception onFallbackError(HystrixInvokable<T> commandInstance, Exception e) {
  fallbackEmissions.add(Notification.createOnError(e));
  recordHookCall(executionSequence, "onFallbackError");
  return super.onFallbackError(commandInstance, e);
}

代码示例来源：origin: PipelineAI/pipeline

@Override
public <T> Exception onExecutionError(HystrixInvokable<T> commandInstance, Exception e) {
  executionEmissions.add(Notification.createOnError(e));
  recordHookCall(executionSequence, "onExecutionError");
  return super.onExecutionError(commandInstance, e);
}

代码示例来源：origin: PipelineAI/pipeline

@Override
public <T> Exception onError(HystrixInvokable<T> commandInstance, FailureType failureType, Exception e) {
  commandEmissions.add(Notification.createOnError(e));
  recordHookCall(executionSequence, "onError");
  return super.onError(commandInstance, failureType, e);
}

代码示例来源：origin: konmik/nucleus

@Override
  public void call(Action2 onNext, Action2 onError) {
    Throwable throwable = new Throwable();
    new Delivery(1, Notification.createOnError(throwable)).split(onNext, onError);
    verify(onError, times(1)).call(1, throwable);
  }
});

代码示例来源：origin: konmik/nucleus

deliveries.add(new Delivery<Object, Integer>(100, Notification.<Integer>createOnError(throwable)));

代码示例来源：origin: konmik/nucleus

deliveries.add(new Delivery<Object, Integer>(101, Notification.<Integer>createOnError(throwable)));
deliveries.add(new Delivery<Object, Integer>(102, Notification.<Integer>createOnError(throwable)));

代码示例来源：origin: konmik/nucleus

deliveries.add(new Delivery<Object, Integer>(101, Notification.<Integer>createOnError(throwable)));

代码示例来源：origin: davidmoten/rxjava-extras

@Override
public void onError(Throwable e) {
  sub.onNext(Notification.<Out> createOnError(e));
}

代码示例来源：origin: com.netflix.rxjava/rxjava-core

@Override
public void onError(Throwable e) {
  notifications.offer(Notification.<T>createOnError(e));
}

代码示例来源：origin: com.github.davidmoten/rxjava-extras

@Override
public void onError(Throwable e) {
  sub.onNext(Notification.<Out> createOnError(e));
}

代码示例来源：origin: com.netflix.rxjava/rxjava-core

@Override
public final void onError(Throwable e) {
  onNotification.call(Notification.createOnError(e));
}

代码示例来源：origin: com.netflix.rxjava/rxjava-core

@Override
public void onError(Throwable e) {
  RxJavaPlugins.getInstance().getErrorHandler().handleError(e);
  child.onNext(Notification.<T> createOnError(e));
  child.onCompleted();
}

代码示例来源：origin: com.netflix.rxjava/rxjava-core

@Override
public boolean hasNext() {
  if (iNotif != null && iNotif.isOnError()) {
    throw Exceptions.propagate(iNotif.getThrowable());
  }
  if (iNotif == null || !iNotif.isOnCompleted()) {
    if (iNotif == null) {
      try {
        notify.acquire();
      } catch (InterruptedException ex) {
        Thread.currentThread().interrupt();
        iNotif = Notification.createOnError(ex);
        throw Exceptions.propagate(ex);
      }
      @SuppressWarnings("unchecked")
      Notification<? extends T> n = (Notification<? extends T>)REFERENCE_UPDATER.getAndSet(this, null);
      iNotif = n;
      if (iNotif.isOnError()) {
        throw Exceptions.propagate(iNotif.getThrowable());
      }
    }
  }
  return !iNotif.isOnCompleted();
}