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

Nullable.<init>介绍

暂无

代码示例

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

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

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

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

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

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

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

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

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

/**
   * 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: akarnokd/RxJava3-preview

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

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

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

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

/**
 * Sets a Disposable on this emitter; any previous Disposable
 * or Cancellation will be unsubscribed/cancelled.
 * @param s the disposable, null is allowed
 */
void setDisposable(@Nullable Disposable s);

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

/**
 * 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: akarnokd/RxJava3-preview

/**
 * Returns the current hook function.
 * @return the hook function, may be null
 */
@Nullable
@SuppressWarnings("rawtypes")
public static BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> getOnFlowableSubscribe() {
  return onFlowableSubscribe;
}

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

/**
 * Returns the current hook function.
 * <p>History: 2.0.6 - experimental
 * @return the hook function, may be null
 * @since 2.1
 */
@SuppressWarnings("rawtypes")
@Nullable
public static Function<? super ParallelFlowable, ? extends ParallelFlowable> getOnParallelAssembly() {
  return onParallelAssembly;
}

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

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

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

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

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

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

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

@Nullable
@Override
public Integer poll() throws Exception {
  return null;
}

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

@Nullable
@Override
public Integer poll() throws Exception {
  return null;
}
@Override

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

@Nullable
@Override
public T poll() throws Throwable {
  T v = qs.poll();
  if (v == null && syncFused) {
    runFinally();
  }
  return v;
}

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

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

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

@Nullable
@Override
public T poll() {
  if (get() == NO_REQUEST) {
    lazySet(REQUESTED);
    return value;
  }
  return null;
}

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

@Nullable
  @Override
  public U poll() throws Exception {
    T t = qs.poll();
    return t != null ? ObjectHelper.<U>requireNonNull(mapper.apply(t), "The mapper function returned a null value.") : null;
  }
}