为什么onNext在使用toList时没有被调用

Question

在使用RxJava toList操作符时，我遇到了onNext未被调用的问题。一切工作完全如我所料，直到toList被调用。我在这里读到的东西，这里和这里似乎表明onCompleted未被调用的问题，但我仍然是RxJava的新手，所以我不确定在哪里需要调用它才能使其工作。

最令人困惑的是，我试图从谷歌的Android架构遵循的架构似乎没有调用onCompleted，它工作得很好。

Subscription subscription = mDataSource
        // Get Observable<List<Location>> from SQLBrite database
        .getLocations()
        // Convert to Location object
        .flatMap(new Func1<List<Location>, Observable<Location>>() {
            @Override
            public Observable<Location> call(List<Location> locations) {
                return Observable.from(locations);
            }
        })
        // Filter here
        .filter(new Func1<Location, Boolean>() {
            @Override
            public Boolean call(Location location) {
                return mPreferences.getUsesCustomLocations() || location.getId().length() <= 2;
            }
        })
        // Convert Location object to String
        .map(new Func1<Location, String>() {
            @Override
            public String call(Location location) {
                return location.getTitle();
            }
        })
        // Convert to Observable<List<String>, however using toList()
        // causes onNext() to never get called
        .toList()
        .subscribeOn(mSchedulerProvider.computation())
        .observeOn(mSchedulerProvider.ui())
        .subscribe(new Observer<List<String>>() {
            @Override
            public void onCompleted() {
            }
            @Override
            public void onError(Throwable e) {
                e.printStackTrace();
            }
            @Override
            public void onNext(List<String> locations) {
                processLocations(locations);
            }
        });
    mSubscriptions.add(subscription);

Answer 1

调用toList()后，您将只获得一个onNext()，这是当源可观察对象调用onComplete()时。

你所看到的行为的原因是SQLBrite，它会发送给你的数据，每次它被改变。这意味着它是一个永无止境的流，所以它最终不会调用onComplete()。