RxJavaがScheduler.io（）スレッドで機能しない

Question

問題は：ObservableとSubscriberです。私は（私は、コードが表示されません - 大きすぎる）、それはファイルやジップアーカイバで動作するので、.io()スレッドでObservableを起動しようとするが、私はせずに、コードを起動するとObservableは!:

Observable<Double> creatingObservable = getCreatingObservable(image); 
Subscriber<Double> creatingSubscriber = getCreatingSubscriber(); 

creatingObservable 
     .subscribeOn(Schedulers.io()) 
     .subscribe(creatingSubscriber); 

何もしませんsubscribeOn() - すべての作品。問題とは何か、それを解決する方法

P.S. System.out.println（）も機能しません。問題はすべてのスケジューラーのスレッドを持っています。

Answer 1

問題があると思われますcreatingObservableの前にメインスレッドが終了した場合、どの値も出力される可能性があります。

簡単な解決策：メインスレッドがcreatingObservableが放出/完了するのに十分長い時間待ちます。

Observable<Double> creatingObservable = getCreatingObservable(image); 
Subscriber<Double> creatingSubscriber = getCreatingSubscriber(); 

creatingObservable 
     .subscribeOn(Schedulers.io()) 
     .subscribe(creatingSubscriber); 

Thread.sleep(5000); //to wait 5 seconds while creatingObservable is running on IO thread 

Answer 2

この場合、アプリケーションはobservableを1回だけ作成します。 Observable.defer(()-> creatingObservable)のいずれかを使用すると、.deferオペレータは毎回観測可能な作成を強制します。

Observable.defer(new Func0<Observable<Double>>() { 
      @Override 
      public Observable<Double> call() { 
       return getCreatingObservable(); 
      } 
     }) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(Schedulers.io()) 
     .subscribe(getCreatingSubscriber); 

Answer 3

この方法を試してください。

compile 'io.reactivex:rxandroid:1.2.1' 

をここから：

Subscriber<Double> creatingSubscriber = getCreatingSubscriber(); 
Observable.defer(new Func0<Observable<Double>>() { 
    @Override 
    public Observable<Double> call() { 
     return getCreatingObservable(image); 
    } 
}) 
.subscribeOn(Schedulers.io()) 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe(creatingSubscriber); 

は、追加することを忘れないでくださいhttps://github.com/ReactiveX/RxAndroid

説明

getCreatingObservable(image); - ほとんどの場合、通話中に「ハード」な作業をする演算子を使用します。例えば

：

Observable.just(doSomeStuff()) 
    .subscribeOn(...) 
    .observeOn(...) 

したがって、実行プロセスは次のようになります

1）。計算するdoSomeStuff()

2）。結果をObservable.just()

3）に渡します。あなただけがあなたに合格するスケジューラを適用しています

つまり、最初に「ハード」作業をしてから、スケジューラを適用しています。あなたはより多くの説明についてObservable.defer()

を使用する必要がある理由です

は、ダン・ルーのこの記事を読んでください：
http://blog.danlew.net/2014/10/08/grokking-rxjava-part-4/

節古い、遅いコード