下面列出了怎么用io.reactivex.rxjava3.core.SingleEmitter的API类实例代码及写法,或者点击链接到github查看源代码。
/**
* 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);
}
});
}
});
}
RemoteLndSingleObserver(SingleEmitter<V> emitter) {
mEmitter = emitter;
}
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));
}