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

Notification.createOnError介绍

[英]Constructs an onError notification containing the error.
[中]构造一个包含错误的OneError通知。

代码示例

代码示例来源：origin: akarnokd/RxJava3-preview

@Override
  public void accept(Throwable v) throws Exception {
    onNotification.accept(Notification.<T>createOnError(v));
  }
}

代码示例来源：origin: com.github.akarnokd/rxjava3-common

@Override
  public void accept(Throwable v) throws Exception {
    onNotification.accept(Notification.<T>createOnError(v));
  }
}

代码示例来源：origin: com.github.akarnokd.rxjava3/rxjava3-common

@Override
  public void accept(Throwable v) throws Exception {
    onNotification.accept(Notification.<T>createOnError(v));
  }
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Override
public void onError(Throwable t) {
  complete(Notification.<T>createOnError(t));
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Override
public void onError(Throwable t) {
  Notification<T> v = Notification.createOnError(t);
  actual.onNext(v);
  actual.onComplete();
}

代码示例来源：origin: com.github.akarnokd.rxjava3/rxjava3-observable

@Override
public void onError(Throwable t) {
  Notification<T> v = Notification.createOnError(t);
  actual.onNext(v);
  actual.onComplete();
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Test
public void testOnErrorIntegerNotificationsWhenEqual() {
  final Exception exception = new Exception();
  final Notification<Integer> onErrorNotification = Notification.createOnError(exception);
  final Notification<Integer> onErrorNotification2 = Notification.createOnError(exception);
  Assert.assertTrue(onErrorNotification.equals(onErrorNotification2));
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Test
  public void testOnErrorIntegerNotificationWhenNotEqual() {
    final Notification<Integer> onErrorNotification = Notification.createOnError(new Exception());
    final Notification<Integer> onErrorNotification2 = Notification.createOnError(new Exception());
    Assert.assertFalse(onErrorNotification.equals(onErrorNotification2));
  }
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Test
@Ignore("Nulls are not allowed")
public void testOnErrorNullNotificationDoesNotEqualIntegerNotification() {
  final Notification<Integer> integerNotification = Notification.createOnError(new Exception());
  final Notification<Integer> nullNotification = Notification.createOnError(null);
  Assert.assertFalse(nullNotification.equals(integerNotification));
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Test
@Ignore("Nulls are not allowed")
public void testOnErrorIntegerNotificationDoesNotEqualNullNotification() {
  final Notification<Integer> integerNotification = Notification.createOnError(new Exception());
  final Notification<Integer> nullNotification = Notification.createOnError(null);
  Assert.assertFalse(integerNotification.equals(nullNotification));
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Override
public boolean hasNext() {
  if (iteratorNotification != null && iteratorNotification.isOnError()) {
    throw ExceptionHelper.wrapOrThrow(iteratorNotification.getError());
  }
  if (iteratorNotification == null) {
    try {
      BlockingHelper.verifyNonBlocking();
      notify.acquire();
    } catch (InterruptedException ex) {
      dispose();
      iteratorNotification = Notification.createOnError(ex);
      throw ExceptionHelper.wrapOrThrow(ex);
    }
    Notification<T> n = value.getAndSet(null);
    iteratorNotification = n;
    if (n.isOnError()) {
      throw ExceptionHelper.wrapOrThrow(n.getError());
    }
  }
  return iteratorNotification.isOnNext();
}

代码示例来源：origin: com.github.akarnokd.rxjava3/rxjava3-observable

@Override
public boolean hasNext() {
  if (iteratorNotification != null && iteratorNotification.isOnError()) {
    throw ExceptionHelper.wrapOrThrow(iteratorNotification.getError());
  }
  if (iteratorNotification == null) {
    try {
      BlockingHelper.verifyNonBlocking();
      notify.acquire();
    } catch (InterruptedException ex) {
      dispose();
      iteratorNotification = Notification.createOnError(ex);
      throw ExceptionHelper.wrapOrThrow(ex);
    }
    Notification<T> n = value.getAndSet(null);
    iteratorNotification = n;
    if (n.isOnError()) {
      throw ExceptionHelper.wrapOrThrow(n.getError());
    }
  }
  return iteratorNotification.isOnNext();
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Override
public boolean hasNext() {
  if (iteratorNotification != null && iteratorNotification.isOnError()) {
    throw ExceptionHelper.wrapOrThrow(iteratorNotification.getError());
  }
  if (iteratorNotification == null || iteratorNotification.isOnNext()) {
    if (iteratorNotification == null) {
      try {
        BlockingHelper.verifyNonBlocking();
        notify.acquire();
      } catch (InterruptedException ex) {
        dispose();
        iteratorNotification = Notification.createOnError(ex);
        throw ExceptionHelper.wrapOrThrow(ex);
      }
      Notification<T> n = value.getAndSet(null);
      iteratorNotification = n;
      if (n.isOnError()) {
        throw ExceptionHelper.wrapOrThrow(n.getError());
      }
    }
  }
  return iteratorNotification.isOnNext();
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Test
public void valueOfOnErrorIsNull() {
  Notification<Integer> notification = Notification.createOnError(new TestException());
  assertNull(notification.getValue());
  assertTrue(notification.getError().toString(), notification.getError() instanceof TestException);
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Override
  protected void subscribeActual(Subscriber<? super Object> observer) {
    observer.onSubscribe(new BooleanSubscription());
    observer.onNext(Notification.createOnComplete());
    observer.onNext(Notification.createOnNext(1));
    observer.onNext(Notification.createOnError(new TestException("First")));
    observer.onError(new TestException("Second"));
  }
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Test
  public void toStringPattern() {
    assertEquals("OnNextNotification[1]", Notification.createOnNext(1).toString());
    assertEquals("OnErrorNotification[io.reactivex.common.exceptions.TestException]", Notification.createOnError(new TestException()).toString());
    assertEquals("OnCompleteNotification", Notification.createOnComplete().toString());
  }
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Override
  protected void subscribeActual(Observer<? super Object> observer) {
    observer.onSubscribe(Disposables.empty());
    observer.onNext(Notification.createOnComplete());
    observer.onNext(Notification.createOnNext(1));
    observer.onNext(Notification.createOnError(new TestException("First")));
    observer.onError(new TestException("Second"));
  }
}

代码示例来源：origin: akarnokd/RxJava3-preview

@Test
public void notEqualsToObject() {
  Notification<Integer> n1 = Notification.createOnNext(0);
  assertFalse(n1.equals(0));
  Notification<Integer> n2 = Notification.createOnError(new TestException());
  assertFalse(n2.equals(0));
  Notification<Integer> n3 = Notification.createOnComplete();
  assertFalse(n3.equals(0));
}