BaseInteractor.java 文件源码

protected <E> SingleObserver<E> getSingleSubscriber(final RxSingleSubscriberEvents singleSubscriberEvents) {
    return new SingleObserver<E>() {

        @Override
        public void onSubscribe(@NonNull Disposable d) {
            queueSubscriptionForDisposal(d);
        }

        @Override
        public void onSuccess(E value) {
            singleSubscriberEvents.onSuccess(value);
        }

        @Override
        public void onError(Throwable error) {
            singleSubscriberEvents.onError(error);
        }
    };
}