io.reactivex.common.annotations.Nullable类的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(144)

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

Nullable介绍

暂无

代码示例

代码示例来源: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-common

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

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

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

代码示例来源: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: com.github.akarnokd.rxjava3/rxjava3-observable

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

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

/**
 * 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: com.github.akarnokd.rxjava3/rxjava3-observable

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

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

/**
 * Returns the error that caused the Subject to terminate or null if the Subject
 * hasn't terminated yet.
 * <p>The method is thread-safe.
 * @return the error that caused the Subject to terminate or null if the Subject
 * hasn't terminated yet
 */
@Nullable
public abstract Throwable getThrowable();

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

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

相关文章