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

Notification.isOnCompleted介绍

[英]Indicates whether this notification represents an onCompleted event.
[中]指示此通知是否表示未完成的事件。

代码示例

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

@Override
  public Boolean call(Notification<T> notification) {
    return !notification.isOnCompleted();
  }
})

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

if (!current.isOnCompleted()) {
  matchFailed = true;
} else {

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

@Override
public boolean hasNext() {
  if (buf == null) {
    buf = take();
  }
  if (buf.isOnError()) {
    throw Exceptions.propagate(buf.getThrowable());
  }
  return !buf.isOnCompleted();
}

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

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

if (nextNotification.isOnCompleted()) {
  return false;

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

@Override
public void call(Message<T> m) {
  if (m.value().isOnCompleted() && onCompleteMessage != null) {
    StringBuilder s = new StringBuilder();
    addDelimited(s, onCompleteMessage);
    addDelimited(s, m.message());
    addMemory(s);
    Logging.log(getLogger(), s.toString(), onCompletedLevel, null);
  } else if (m.value().isOnError() && logOnError) {
    StringBuilder s = new StringBuilder();
    addDelimited(s,
        String.format(onErrorFormat, m.value().getThrowable().getMessage()));
    addDelimited(s, m.message());
    addMemory(s);
    Logging.log(getLogger(), s.toString(), onErrorLevel, m.value()
        .getThrowable());
  } else if (m.value().isOnNext() && logOnNext) {
    StringBuilder s = new StringBuilder();
    if (onNextFormat.length() > 0)
      s.append(String.format(onNextFormat,
          String.valueOf(valueFunction.call(m.value().getValue()))));
    addDelimited(s, m.message());
    addMemory(s);
    addStackTrace(s);
    Logging.log(getLogger(), s.toString(), onNextLevel, null);
  }
}

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

@Override
public void call(Message<T> m) {
  if (m.value().isOnCompleted() && onCompleteMessage != null) {
    StringBuilder s = new StringBuilder();
    addDelimited(s, onCompleteMessage);
    addDelimited(s, m.message());
    addMemory(s);
    Logging.log(getLogger(), s.toString(), onCompletedLevel, null);
  } else if (m.value().isOnError() && logOnError) {
    StringBuilder s = new StringBuilder();
    addDelimited(s,
        String.format(onErrorFormat, m.value().getThrowable().getMessage()));
    addDelimited(s, m.message());
    addMemory(s);
    Logging.log(getLogger(), s.toString(), onErrorLevel, m.value()
        .getThrowable());
  } else if (m.value().isOnNext() && logOnNext) {
    StringBuilder s = new StringBuilder();
    if (onNextFormat.length() > 0)
      s.append(String.format(onNextFormat,
          String.valueOf(valueFunction.call(m.value().getValue()))));
    addDelimited(s, m.message());
    addMemory(s);
    addStackTrace(s);
    Logging.log(getLogger(), s.toString(), onNextLevel, null);
  }
}

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

/**
 * Forwards this notification on to a specified {@link Observer}.
 */
public void accept(Observer<? super T> observer) {
  if (isOnNext()) {
    observer.onNext(getValue());
  } else if (isOnCompleted()) {
    observer.onCompleted();
  } else if (isOnError()) {
    observer.onError(getThrowable());
  }
}