BehaviorSubject を使って Activity と Fragment のデータの読み込みを待ち合わせる

画面構成は

• MainActivity
  • TabLayout + ViewPager
  • ViewPagerの各ページは MainFragment
• MainFragment
  • RecyclerView

やりたいことは

• MainActivity
  • 各ページで共通のデータ（以後 CommonData）をサーバーから取得する
• MainFragment
  • ページ特有のデータ（以後 SpecificData）をサーバーから取得する
  • MainActivity から CommonData をもらう
  • CommonData と SpecificData 両方の読み込みが終わったら RecyclerView にデータを追加する

キモになるのが、CommonData と SpecificData 両方の読み込みが終わるのを待ち合わせたいというところです。
CommonData の読み込みが終わる前に生成された MainFragment なら両方の読み込みを待ち合わせるし、 CommonData の読み込みが終わった後に生成された MainFragment なら SpecificData の読み込みだけ待てばいいわけです。
でも、この2つの状態をわけて処理すると煩雑になってしまいます。

そこで、BehaviorSubject を使って、CommonData の値を MainFragment 側に渡せるようにします。 BehaviorSubject は onNext() が呼ばれたときにその値を通知し、さらにその値をキャッシュします。新しく subscribe されると、最新のキャッシュした値があればその時点で通知します。

view plainprint?

1. public class MainActivity extends AppCompatActivity implements MainFragment.MainFragmentListener {  
2.   
3.     private final BehaviorSubject<CommonData> commonDataBehaviorSubject = BehaviorSubject.create();  
4.   
5.     @Override  
6.     protected void onCreate(Bundle savedInstanceState) {  
7.         super.onCreate(savedInstanceState);  
8.         ...  
9.   
10.         loadCommonData();  
11.     }  
12.   
13.     private void loadCommonData() {  
14.         subscription = DataRetriever.getInstance().getCommonData()  
15.                 .onErrorReturn(new Func1<Throwable, CommonData>() {  
16.                     @Override  
17.                     public CommonData call(Throwable throwable) {  
18.                         // エラーのときはデータがないものとして扱う  
19.                         return CommonData.empty();  
20.                     }  
21.                 })  
22.                 .subscribe(new Action1<CommonData>() {  
23.                     @Override  
24.                     public void call(CommonData commonData) {  
25.                         commonDataBehaviorSubject.onNext(commonData);  
26.                     }  
27.                 });  
28.     }  
29.   
30.     @NonNull  
31.     @Override  
32.     public Observable<CommonData> getCommonDataObservable() {  
33.         return commonDataBehaviorSubject;  
34.     }  
35. }  

public class MainActivity extends AppCompatActivity implements MainFragment.MainFragmentListener { private final BehaviorSubject<CommonData> commonDataBehaviorSubject = BehaviorSubject.create(); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); ... loadCommonData(); } private void loadCommonData() { subscription = DataRetriever.getInstance().getCommonData() .onErrorReturn(new Func1<Throwable, CommonData>() { @Override public CommonData call(Throwable throwable) { // エラーのときはデータがないものとして扱う return CommonData.empty(); } }) .subscribe(new Action1<CommonData>() { @Override public void call(CommonData commonData) { commonDataBehaviorSubject.onNext(commonData); } }); } @NonNull @Override public Observable<CommonData> getCommonDataObservable() { return commonDataBehaviorSubject; } }

view plainprint?

1. public class MainFragment extends Fragment {  
2.   
3.     public interface MainFragmentListener {  
4.   
5.         @NonNull  
6.         Observable<CommonData> getCommonDataObservable();  
7.     }  
8.   
9.     @Nullable  
10.     private MainFragmentListener listener;  
11.   
12.     ...  
13.   
14.     @Override  
15.     public void onAttach(Context context) {  
16.         super.onAttach(context);  
17.         if (context instanceof MainFragmentListener) {  
18.             listener = (MainFragmentListener) context;  
19.         }  
20.     }  
21.   
22.     @Override  
23.     public void onActivityCreated(@Nullable Bundle savedInstanceState) {  
24.         super.onActivityCreated(savedInstanceState);  
25.         if (adapter == null) {  
26.             adapter = new DataAdapter();  
27.             load();  
28.         }  
29.         recyclerView.setAdapter(adapter);  
30.     }  
31.   
32.     void load() {  
33.         recyclerView.setVisibility(View.GONE);  
34.         progressView.setVisibility(View.VISIBLE);  
35.   
36.         // 共通データとタブ独自のデータ両方揃うまで待ち合わせ  
37.         subscription = Observable  
38.                 .combineLatest(  
39.                         getCommonDataObservable(),  
40.                         getSpecificDataObservable(),  
41.                         new Func2<CommonData, SpecificData, Pair<CommonData, SpecificData>>() {  
42.                             @Override  
43.                             public Pair<CommonData, SpecificData> call(CommonData commonData, SpecificData specificData) {  
44.                                 return new Pair<>(commonData, specificData);  
45.                             }  
46.                         })  
47.                 .subscribeOn(Schedulers.newThread())  
48.                 .observeOn(AndroidSchedulers.mainThread())  
49.                 .subscribe(new Subscriber<Pair<CommonData, SpecificData>>() {  
50.                     @Override  
51.                     public void onCompleted() {  
52.                     }  
53.   
54.                     @Override  
55.                     public void onError(Throwable e) {  
56.                         recyclerView.setVisibility(View.VISIBLE);  
57.                         progressView.setVisibility(View.GONE);  
58.                     }  
59.   
60.                     @Override  
61.                     public void onNext(Pair<CommonData, SpecificData> combinedData) {  
62.                         recyclerView.setVisibility(View.VISIBLE);  
63.                         progressView.setVisibility(View.GONE);  
64.   
65.                         final List<String> list = new ArrayList<>();  
66.   
67.                         final CommonData commonData = combinedData.first;  
68.                         list.add("CommonData : " + (commonData.isEmpty() ? "empty" : commonData.getData()));  
69.   
70.                         final SpecificData specificData = combinedData.second;  
71.                         list.addAll(specificData.getData());  
72.   
73.                         adapter.addAll(list);  
74.                     }  
75.                 });  
76.     }  
77.   
78.     /** 
79.      * 共通のデータを取得 
80.      */  
81.     private Observable<CommonData> getCommonDataObservable() {  
82.         return listener != null  
83.                 // first() を介して onComplete()が呼ばれるようにしている  
84.                 ? listener.getCommonDataObservable().first()   
85.                 : Observable.just(CommonData.empty());  
86.     }  
87.   
88.     /** 
89.      * このタブ独自のデータを取得 
90.      */  
91.     private Observable<SpecificData> getSpecificDataObservable() {  
92.         final int position = getArguments() == null ? -1 : getArguments().getInt(ARGS_POSITION);  
93.         return DataRetriever.getInstance().getSpecificData(position);  
94.     }  
95.   
96.     ...  
97. }  

public class MainFragment extends Fragment { public interface MainFragmentListener { @NonNull Observable<CommonData> getCommonDataObservable(); } @Nullable private MainFragmentListener listener; ... @Override public void onAttach(Context context) { super.onAttach(context); if (context instanceof MainFragmentListener) { listener = (MainFragmentListener) context; } } @Override public void onActivityCreated(@Nullable Bundle savedInstanceState) { super.onActivityCreated(savedInstanceState); if (adapter == null) { adapter = new DataAdapter(); load(); } recyclerView.setAdapter(adapter); } void load() { recyclerView.setVisibility(View.GONE); progressView.setVisibility(View.VISIBLE); // 共通データとタブ独自のデータ両方揃うまで待ち合わせ subscription = Observable .combineLatest( getCommonDataObservable(), getSpecificDataObservable(), new Func2<CommonData, SpecificData, Pair<CommonData, SpecificData>>() { @Override public Pair<CommonData, SpecificData> call(CommonData commonData, SpecificData specificData) { return new Pair<>(commonData, specificData); } }) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber<Pair<CommonData, SpecificData>>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { recyclerView.setVisibility(View.VISIBLE); progressView.setVisibility(View.GONE); } @Override public void onNext(Pair<CommonData, SpecificData> combinedData) { recyclerView.setVisibility(View.VISIBLE); progressView.setVisibility(View.GONE); final List<String> list = new ArrayList<>(); final CommonData commonData = combinedData.first; list.add("CommonData : " + (commonData.isEmpty() ? "empty" : commonData.getData())); final SpecificData specificData = combinedData.second; list.addAll(specificData.getData()); adapter.addAll(list); } }); } /** * 共通のデータを取得 */ private Observable<CommonData> getCommonDataObservable() { return listener != null // first() を介して onComplete()が呼ばれるようにしている ? listener.getCommonDataObservable().first() : Observable.just(CommonData.empty()); } /** * このタブ独自のデータを取得 */ private Observable<SpecificData> getSpecificDataObservable() { final int position = getArguments() == null ? -1 : getArguments().getInt(ARGS_POSITION); return DataRetriever.getInstance().getSpecificData(position); } ... }

さらに、MainActivity に SwipeRefreshLayout を追加して、PullToRefresh で共通データを取り直し、各 MainFragment にもデータを取り直させる処理を追加したサンプルが
https://github.com/yanzm/BehaviorSubjectSample
です。

• MainActivity
• MainFragment