Android RxJavaの並列化 - ExecutorServiceによる計算

Question

私はRxJavaで小さなJavaプログラムを正常に実行しました。コードは：

public static void main(String[] args) { 
     int threadCt = Runtime.getRuntime().availableProcessors() + 1; 
     //multi-threading 
     ExecutorService executor = Executors.newFixedThreadPool(threadCt); 
     Scheduler scheduler = Schedulers.from(executor); 

     final AtomicInteger batch = new AtomicInteger(0); 

     Observable.range(1,80) 
      .groupBy(i -> batch.getAndIncrement() % threadCt) 
      .flatMap(g -> g.observeOn(scheduler) 
        .map(i -> intenseCalculation(i)) 
      ).subscribe(System.out::println); 
    } 



    public static int intenseCalculation(int i) { 
     try { 
      System.out.println("Calculating " + i + 
       " on " + Thread.currentThread().getName()); 
      Thread.sleep(500); 
      return i; 
     } catch (InterruptedException e) { 
     throw new RuntimeException(e); 
     } 
    } 

このコードではすべて正常に動作します。今私は、Androidにこのコードを渡ししようとしています：

 Scheduler scheduler = Schedulers.from(executor); 

     final AtomicInteger batch = new AtomicInteger(0); 
     Observable.range(0, copiedCategories.size() - 1) 
       .groupBy(i -> batch.getAndIncrement() % threadCt) 
       .flatMap(g -> g.observeOn(scheduler)) 
       .map(i -> intenseCalculation(i)) 
       .subscribe(finishedListener::finished); 

メソッド内（finishedListenerは、現在の活動を実施しているインタフェースである）私は、GUIを更新しています）（終了。私が使用しています（アプリ用）build.gradleで

no instance(s) of type variable(s) exist so that void conforms to R 

：

compile 'io.reactivex:rxjava:1.2.9' 

- （> intenseCalculation（I）は、i）

私はマップとライン上のエラーを取得しています

どうすれば問題を解決できますか？

.flatMap(g -> g.observeOn(scheduler) 
       .map(i -> intenseCalculation(i)) 
     ) 

しかし、Androidのコードでは、メインストリームにmap()を実行している：あなたが持っているJavaコードで

Answer 1

ので

.flatMap(g -> g.observeOn(scheduler)) 
.map(i -> intenseCalculation(i)) 

、これらは同じものではありません、あなたは内の余分なブラケットを持っていますAndroidロジックは、ストリームロジックを完全に変更します。

注、あなたはUIスレッド上でUI関連の操作を実行する必要があるので、あなたは、ストリームをサブスクライブする前にobserveOn(AndroidSchedulers.mainThread())を実行する必要があり、そうでなければ、クラッシュで終わると思います。