在自定义应用程序子类中使用Observable

Question

问题是，就应用程序生命周期处理和易于使用而言，这种体系结构是否可以被认为是安全的？

class CustomApplication extends Application {
   ...

   BehaviorSubject<Friends> mFriends = new BehaviorSubject<Friends>;
   public void createObservables() {
      Observable.create(new Observable.OnSubscribe<Friends>() {
         public void call(Subscriber<?> s) {
            while(true) {
               mFriends.onNext("randomFriendN");
               sleep(10sec);
            }
         }
      })
      .subscribeOn(Schedulers.newThread())
      .subscribe(new Observer<List<NewsCategory>>() {
         public void onNext(Friends f) { //empty }
      });
   }
   public BehaviorSubject<Friends> getFriends() {
      return mFriends;
   }
}

Update：每次创建新的活动并希望获得数据时，它可以获得ApplicationContext的BehaviorSubject，然后订阅它，Subject将发出最后发出的值；我为什么要这样做？例如。假设你有新闻项目，你获取了新闻提要，你想启动后台任务来获取新闻项目的全部内容，在这种情况下，我可以在你滚动新闻列表时开始获取数据，当你单击详细活动时，我们可以从已经获取的数据中显示它，或者只是下载它。

Answer 1

我认为这是完全安全的，只要在应用程序初始化期间只调用createObservables（）一次。一些建议的改变...

我不会在从getFriends（）返回的值中公开mFriends的BehaviorSubject部分。这样，getFriends（）的调用者就不会想要调用onNext（）。将其更改为：

public Observable<Friends> getFriends() {
    return mFriends;
}

如果您想要超级安全，那么使用。asObservable()，调用者甚至不能将返回值强制转换回BehaviorSubject。

public Observable<Friends> getFriends() {
    return mFriends.asObservable();
}

BehaviorSubject<List<NewsItem>> mNewsItemSubject = BehaviorSubject.create();

void createObservables() {
    Observable
            .timer(10, 10, TimeUnit.SECONDS, Schedulers.newThread())
            .flatMap(new Func1<Long, Observable<List<NewsItem>>>() {
                @Override
                public Observable<List<NewsItem>> call(Long aLong) {
                    // Normally you would create a network API that returns Observable<NewsItem>.
                    // For now just pretend this returned Observable makes an Observable
                    // network request.
                    return Observable.just(
                            Arrays.asList(
                                    new NewsItem("fakeNewsItem"),
                                    new NewsItem("fakeNewsItem1")
                            )
                    );
                }
            })
            .subscribe(new Action1<List<NewsItem>>() {
                @Override
                public void call(List<NewsItem> newsItems) {
                    mNewsItemSubject.onNext(newsItems);
                }
            });
}

public Observable<List<NewsItem>> observeNewsItems() {
    return mNewsItemSubject;
}

final Observable<List<NewsItem>> newsItemsObservable = 
    ((CustomApplication) getApplication()).observeNewsItems();

newsItemsObservable
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Observer<List<NewsItem>>() {
            @Override
            public void onCompleted() {
                // All done.
            }

            @Override
            public void onError(Throwable e) {
                // Notify user of error (maybe)
            }

            @Override
            public void onNext(List<NewsItem> newsItems) {
                // Update the UI with newsItems.
            }
        });