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

Notification.createOnComplete介绍

[英]Returns the empty and stateless shared instance of a notification representing an onComplete signal.
[中]返回表示未完成信号的通知的空的无状态共享实例。

代码示例

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

@Override
  public void run() throws Exception {
    onNotification.accept(Notification.<T>createOnComplete());
  }
}

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

@Override
  public void run() throws Exception {
    onNotification.accept(Notification.<T>createOnComplete());
  }
}

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

@Override
  public void run() throws Exception {
    onNotification.accept(Notification.<T>createOnComplete());
  }
}

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

@Override
public void onComplete() {
  complete(Notification.<T>createOnComplete());
}

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

/**
 * Returns a list of 3 other lists: the first inner list contains the plain
 * values received; the second list contains the potential errors
 * and the final list contains the potential completions as Notifications.
 *
 * @return a list of (values, errors, completion-notifications)
 */
@SuppressWarnings({ "rawtypes", "unchecked" })
public final List<List<Object>> getEvents() {
  List<List<Object>> result = new ArrayList<List<Object>>();
  result.add((List)values());
  result.add((List)errors());
  List<Object> completeList = new ArrayList<Object>();
  for (long i = 0; i < completions; i++) {
    completeList.add(Notification.createOnComplete());
  }
  result.add(completeList);
  return result;
}

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

@Override
  public void onComplete() {
    Notification<T> v = Notification.createOnComplete();
    actual.onNext(v);
    actual.onComplete();
  }
}

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

@Override
  public void onComplete() {
    Notification<T> v = Notification.createOnComplete();
    actual.onNext(v);
    actual.onComplete();
  }
}

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

@Test
public void badSource() {
  TestHelper.checkBadSourceFlowable(new Function<Flowable<Object>, Object>() {
    @Override
    public Object apply(Flowable<Object> f) throws Exception {
      return f.materialize();
    }
  }, false, null, null, Notification.createOnComplete());
}

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

@Test
public void hashCodeIsTheInner() {
  Notification<Integer> n1 = Notification.createOnNext(1337);
  assertEquals(Integer.valueOf(1337).hashCode(), n1.hashCode());
  assertEquals(0, Notification.createOnComplete().hashCode());
}

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

@Test
public void dispose() {
  TestHelper.checkDisposed(Observable.just(Notification.createOnComplete()).dematerialize());
}

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

@Test
public void dispose() {
  TestHelper.checkDisposed(Flowable.just(Notification.createOnComplete()).dematerialize());
}

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

@SuppressWarnings("unchecked")
@Test
public void onNext() {
  TestObserver<Integer> ts = TestObserver.create();
  ts.onSubscribe(Disposables.empty());
  assertEquals(0, ts.valueCount());
  assertEquals(Collections.emptyList(), ts.values());
  ts.onNext(1);
  assertEquals(Collections.singletonList(1), ts.values());
  ts.cancel();
  assertTrue(ts.isCancelled());
  assertTrue(ts.isDisposed());
  ts.assertValue(1);
  assertEquals(Arrays.asList(Collections.singletonList(1), Collections.emptyList(), Collections.emptyList()), ts.getEvents());
  ts.onComplete();
  assertEquals(Arrays.asList(Collections.singletonList(1), Collections.emptyList(), Collections.singletonList(Notification.createOnComplete())), ts.getEvents());
}

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

@SuppressWarnings("unchecked")
@Test
public void onNext() {
  TestSubscriber<Integer> ts = TestSubscriber.create();
  ts.onSubscribe(new BooleanSubscription());
  assertEquals(0, ts.valueCount());
  assertEquals(Collections.emptyList(), ts.values());
  ts.onNext(1);
  assertEquals(Collections.singletonList(1), ts.values());
  ts.cancel();
  assertTrue(ts.isCancelled());
  assertTrue(ts.isDisposed());
  ts.assertValue(1);
  assertEquals(Arrays.asList(Collections.singletonList(1), Collections.emptyList(), Collections.emptyList()), ts.getEvents());
  ts.onComplete();
  assertEquals(Arrays.asList(Collections.singletonList(1), Collections.emptyList(), Collections.singletonList(Notification.createOnComplete())), ts.getEvents());
}

代码示例来源：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 valueOfOnCompleteIsNull() {
  Notification<Integer> notification = Notification.createOnComplete();
  assertNull(notification.getValue());
  assertNull(notification.getError());
  assertTrue(notification.isOnComplete());
}

代码示例来源：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));
}

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

@Test
public void nextObserverOnCompleteOnNext() throws Exception {
  NextSubscriber<Integer> no = new NextSubscriber<Integer>();
  no.setWaiting();
  no.onNext(Notification.<Integer>createOnComplete());
  no.setWaiting();
  no.onNext(Notification.createOnNext(1));
  assertTrue(no.takeNext().isOnComplete());
}

代码示例来源：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 nextObserverOnCompleteOnNext() throws Exception {
    NextObserver<Integer> no = new NextObserver<Integer>();

    no.setWaiting();
    no.onNext(Notification.<Integer>createOnComplete());

    no.setWaiting();
    no.onNext(Notification.createOnNext(1));

    assertTrue(no.takeNext().isOnComplete());
  }
}