类io.reactivex.rxjava3.core.SingleEmitter源码实例Demo

下面列出了怎么用io.reactivex.rxjava3.core.SingleEmitter的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: apollo-android   文件: Rx3Apollo.java
/**
 * Converts an {@link ApolloStoreOperation} to a Single.
 *
 * @param operation the ApolloStoreOperation to convert
 * @param <T>       the value type
 * @return the converted Single
 */
@NotNull
@CheckReturnValue
public static <T> Single<T> from(@NotNull final ApolloStoreOperation<T> operation) {
  checkNotNull(operation, "operation == null");
  return Single.create(new SingleOnSubscribe<T>() {
    @Override
    public void subscribe(final SingleEmitter<T> emitter) {
      operation.enqueue(new ApolloStoreOperation.Callback<T>() {
        @Override
        public void onSuccess(T result) {
          emitter.onSuccess(result);
        }

        @Override
        public void onFailure(Throwable t) {
          emitter.onError(t);
        }
      });
    }
  });
}
 
源代码2 项目: zap-android   文件: RemoteLndSingleObserver.java
RemoteLndSingleObserver(SingleEmitter<V> emitter) {
    mEmitter = emitter;
}
 
源代码3 项目: java-11-examples   文件: SingleDataProducerTask.java
public SingleDataProducerTask(SingleEmitter<DataItem> emitter, SingleDataQuery dataQuery) {
    this.emitter = emitter;
    this.dataQuery = dataQuery;
    this.disposed = false;
}
 
@Override
public void subscribe(SingleEmitter<DataItem> emitter) throws Throwable {
    this.executor.execute(new SingleDataProducerTask(emitter, dataQuery));
}
 
 类所在包
 类方法
 同包方法