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

Nullable.<init>介绍

暂无

代码示例

代码示例来源：origin: ReactiveX/RxJava

@Nullable
@Override
public Object poll() throws Exception {
  return null; // always empty
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Sets a Cancellable on this emitter; any previous {@link Disposable}
 * or {@link Cancellable} will be disposed/cancelled.
 * @param c the cancellable resource, null is allowed
 */
void setCancellable(@Nullable Cancellable c);

代码示例来源：origin: ReactiveX/RxJava

/**
 * Constructs a GroupedFlowable with the given key.
 * @param key the key
 */
protected GroupedFlowable(@Nullable K key) {
  this.key = key;
}

代码示例来源：origin: ReactiveX/RxJava

@Override
@Nullable
public Throwable getThrowable() {
  if (done) {
    return error;
  }
  return null;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Returns the a hook consumer.
 * @return the hook consumer, may be null
 */
@Nullable
public static Consumer<? super Throwable> getErrorHandler() {
  return errorHandler;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Returns the current hook function.
 * @return the hook function, may be null
 */
@Nullable
public static Function<? super Scheduler, ? extends Scheduler> getIoSchedulerHandler() {
  return onIoHandler;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Returns the current hook function.
 * @return the hook function, may be null
 */
@SuppressWarnings("rawtypes")
@Nullable
public static Function<? super ConnectableFlowable, ? extends ConnectableFlowable> getOnConnectableFlowableAssembly() {
  return onConnectableFlowableAssembly;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Returns the current hook function.
 * @return the hook function, may be null
 */
@Nullable
@SuppressWarnings("rawtypes")
public static Function<? super Maybe, ? extends Maybe> getOnMaybeAssembly() {
  return onMaybeAssembly;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Sets a Disposable on this emitter; any previous {@link Disposable}
 * or {@link Cancellable} will be disposed/cancelled.
 * @param d the disposable, null is allowed
 */
void setDisposable(@Nullable Disposable d);

代码示例来源：origin: ReactiveX/RxJava

/**
   * Returns the key that identifies the group of items emitted by this {@code GroupedObservable}.
   *
   * @return the key that the items emitted by this {@code GroupedObservable} were grouped by
   */
  @Nullable
  public K getKey() {
    return key;
  }
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Returns the success value if this SingleSubject was terminated with a success value.
 * @return the success value or null
 */
@Nullable
public T getValue() {
  if (observers.get() == TERMINATED) {
    return value;
  }
  return null;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Sets the specific hook function.
 * @param handler the hook function to set, null allowed
 */
public static void setSingleSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) {
  if (lockdown) {
    throw new IllegalStateException("Plugins can't be changed anymore");
  }
  onSingleHandler = handler;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Sets the specific hook function.
 * @param onCompletableSubscribe the hook function to set, null allowed
 */
public static void setOnCompletableSubscribe(
    @Nullable BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe) {
  if (lockdown) {
    throw new IllegalStateException("Plugins can't be changed anymore");
  }
  RxJavaPlugins.onCompletableSubscribe = onCompletableSubscribe;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Sets the specific hook function.
 * @param onConnectableFlowableAssembly the hook function to set, null allowed
 */
@SuppressWarnings("rawtypes")
public static void setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly) {
  if (lockdown) {
    throw new IllegalStateException("Plugins can't be changed anymore");
  }
  RxJavaPlugins.onConnectableFlowableAssembly = onConnectableFlowableAssembly;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Sets the specific hook function.
 * @param onConnectableObservableAssembly the hook function to set, null allowed
 */
@SuppressWarnings("rawtypes")
public static void setOnConnectableObservableAssembly(@Nullable Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly) {
  if (lockdown) {
    throw new IllegalStateException("Plugins can't be changed anymore");
  }
  RxJavaPlugins.onConnectableObservableAssembly = onConnectableObservableAssembly;
}

代码示例来源：origin: ReactiveX/RxJava

/**
 * Returns a single value the Subject currently has or null if no such value exists.
 * <p>The method is thread-safe.
 * @return a single value the Subject currently has or null if no such value exists
 */
@Nullable
public T getValue() {
  return buffer.getValue();
}

代码示例来源：origin: ReactiveX/RxJava

@Nullable
@Override
public Long poll() throws Exception {
  long i = index;
  if (i != end) {
    index = i + 1;
    return i;
  }
  lazySet(1);
  return null;
}

代码示例来源：origin: ReactiveX/RxJava

@Override
@Nullable
public Throwable getThrowable() {
  Object o = value.get();
  if (NotificationLite.isError(o)) {
    return NotificationLite.getError(o);
  }
  return null;
}

代码示例来源：origin: ReactiveX/RxJava

@Nullable
@Override
public final T poll() throws Exception {
  if (get() == FUSED_READY) {
    T v = value;
    value = null;
    lazySet(FUSED_CONSUMED);
    return v;
  }
  return null;
}

代码示例来源：origin: ReactiveX/RxJava

@Nullable
  @Override
  public T poll() throws Exception {
    T v = qd.poll();
    if (v != null) {
      onAfterNext.accept(v);
    }
    return v;
  }
}