RxJavaを使用してメインスレッドからJSONを解析する

Question

スタートアップ時にいくつかのJSONファイルを解析し、データをデータベースに取り込む必要があります。アプリケーションの起動時に、ファイルが解析されている間にスプラッシュ画面が表示されます。

メインスレッドからすべての解析を実行し、アニメーションをスムーズに進めることができます。

RxJavaのObservable.create()メソッドを使用してObservableを作成することができました。現在のコードを以下に示します。

Observable.create(new Observable.OnSubscribe<Object>() { 
    @Override 
    public void call(Subscriber<? super Object> subscriber) { 
     parseBundles(); 
     parsePhrases(); 
    } 
}) 
.subscribeOn(Schedulers.io()) 
.subscribe(new Subscriber<Object>() { 
    @Override 
    public void onCompleted() { 
     startActivity(new Intent(SplashActivity.this, HomeActivity.class), 
      ActivityOptionsCompat.makeCustomAnimation(SplashActivity.this, 
      android.R.anim.fade_in, android.R.anim.fade_out).toBundle()); 
    } 

    @Override 
    public void onError(Throwable e) { 
     e.printStackTrace(); 
    } 

    @Override 
    public void onNext(Object o) { 

    } 
}); 

これが正常IOスレッドで実行parseBundles()とparsePhrases()方法になります。状況によっては、これらの2つの方法では、ローカル.jsonファイルをInputStreamでロードし、.jsonをString変数にスローすると、該当するJSONObjectsが取り出され、データがDBに保存されます。

ただし、onCompleted()は呼び出されません。 parseBundles()とparsePhrases()の両方の方法は、Rxコードを使用しない単純な古い方法です。私が理解しているように、完成すると何かを適切に放出するように修正する必要があります。

このコードを説明どおりに動作させるにはどうすればよいですか？これは現在RxJava 1を使って書かれていますが、RxJava 2を使った回答も受け入れられることに注意してください。

Answer 1

観測が適切に構築されていないあなた、あなたは非同期プロセスを自分で運転する必要があります。

Observable.create(new Observable.OnSubscribe<Object>() { 
    @Override 
    public void call(Subscriber<? super Object> subscriber) { 
    parseBundles(); 
    parsePhrases(); 
    subscriber.onCompleted(); 
    } 
}) 

さておき、私はObservable.createを憎むとして - それはあまりにも低レベルだとあまりにも多くの人々はそれが間違って最初に取得します2〜3回;なぜチュートリアルがそれから始まるのか理解できませんでした。