paging/rxjava2/src/main/java/androidx/paging/RxPagedListBuilder.java
@NonNull
    public Observable<PagedList<Value>> buildObservable() {
        if (mNotifyExecutor == null) {
            mNotifyExecutor = ArchTaskExecutor.getMainThreadExecutor();
            mNotifyScheduler = Schedulers.from(mNotifyExecutor);
        }
        if (mFetchExecutor == null) {
            mFetchExecutor = ArchTaskExecutor.getIOThreadExecutor();
            mFetchScheduler = Schedulers.from(mFetchExecutor);
        }
        return Observable.create(new PagingObservableOnSubscribe<>(
                mInitialLoadKey,
                mConfig,
                mBoundaryCallback,
                mDataSourceFactory,
                mNotifyExecutor,
                mFetchExecutor))
                        .observeOn(mNotifyScheduler)
                        .subscribeOn(mFetchScheduler);
    }
/**
     * Constructs a {@code Observable<PagedList>}.
     * <p>
     * The returned Observable will already be observed on the
     * {@link #setNotifyScheduler(Scheduler) notify scheduler}, and subscribed on the
     * {@link #setFetchScheduler(Scheduler) fetch scheduler}.
     *
     * @return The Observable of PagedLists
     */
Constructs a  Observable.

The returned Observable will already be observed on the
#setNotifyScheduler(Scheduler) notify scheduler, and subscribed on the
#setFetchScheduler(Scheduler) fetch scheduler.

@return The Observable of PagedLists
Constructs a Observable . The returned Observable will already be observed on the #setNotifyScheduler ( Scheduler ) notify scheduler and subscribed on the #setFetchScheduler ( Scheduler ) fetch scheduler . @return The Observable of PagedLists
@NonNull
    public Observable<PagedList<Value>> buildObservable() {
        if (mNotifyExecutor == null) {
            mNotifyExecutor = ArchTaskExecutor.getMainThreadExecutor();
            mNotifyScheduler = Schedulers.from(mNotifyExecutor);
        }
        if (mFetchExecutor == null) {
            mFetchExecutor = ArchTaskExecutor.getIOThreadExecutor();
            mFetchScheduler = Schedulers.from(mFetchExecutor);
        }
        return Observable.create(new PagingObservableOnSubscribe<>(
                mInitialLoadKey,
                mConfig,
                mBoundaryCallback,
                mDataSourceFactory,
                mNotifyExecutor,
                mFetchExecutor))
                        .observeOn(mNotifyScheduler)
                        .subscribeOn(mFetchScheduler);
    }
@ NonNull public Observable < PagedList < Value > > buildObservable ( ) { if ( mNotifyExecutor == null ) { mNotifyExecutor = ArchTaskExecutor . getMainThreadExecutor ( ) ; mNotifyScheduler = Schedulers . from ( mNotifyExecutor ) ; } if ( mFetchExecutor == null ) { mFetchExecutor = ArchTaskExecutor . getIOThreadExecutor ( ) ; mFetchScheduler = Schedulers . from ( mFetchExecutor ) ; } return Observable . create ( new PagingObservableOnSubscribe < > ( mInitialLoadKey , mConfig , mBoundaryCallback , mDataSourceFactory , mNotifyExecutor , mFetchExecutor ) ) . observeOn ( mNotifyScheduler ) . subscribeOn ( mFetchScheduler ) ; }
Constructs a {@code Observable<PagedList>}.
Constructs a { @code Observable<PagedList > } .