RxJava /アンドロイド：ここでは、元のアイテムの組み合わせとして観察可能と変換項目

Question

は一例で構築：

Student[] students = ...; 
Subscriber<Course> subscriber = new Subscriber<Course>() { 
    @Override 
    public void onNext(Course course) { 
     Log.d(tag, course.getName()); 
    } 
    ... 
}; 
Observable.from(students) 
    .flatMap(new Func1<Student, Observable<Course>>() { 
     @Override 
     public Observable<Course> call(Student student) { 
      return Observable.from(student.getCourses()); 
     } 
    }) 
    .subscribe(subscriber); 

それはコースを観察するのは簡単ですが、私は、スチューデントのペアをプリントアウトするために何をしたい場合コース？それはObservable<Course>をObservable<Pair<Student, Course>>に変更する必要がありますか？このメソッドは変換中に複数の演算子を持つ可能性があるため非常に面倒ですが、Pairsを常に観測可能なものに変換したくないのです。

変換されたアイテムに基づいて元のアイテムを参照できる他の良い方法はありますか？

Answer 1

あなたの目標と実装に応じて、あなたがこのようなflatMapのオーバーロードされたバリアントを使用することができます：あなたは、単に学生のコースのペアを印刷したい場合は

Observable.from(students) 
     .flatMap(new Func1<Student, Observable<Course>>() { 
      @Override 
      public Observable<Course> call(Student student) { 
       return Observable.from(student.getCourses()); 
      } 
     }, new Func2<Student, Course, Void>() { 
      @Override 
      public Void call(Student student, Course course) { 
       Log.d(tag, student + "->" + course.getName()); 
       return null; 
      } 
     }) 
     .subscribe(); 

Answer 2

students.doOnNext(new Action1<String>() { 
      @Override 
      public void call(String student) { 
       ArrayList<String> studentCourses = courses.get(student); 
       for (int i=0 ; i<studentCourses.size() ; i++) { 
        System.out.println(student + " -> " + studentCourses.get(i) + " " + test); 
       } 
      } 
     }) 
     .subscribe(new Subscriber<String>() { 
     @Override 
     public void onNext(String s) { /*System.out.println(s); */} 

     @Override 
     public void onCompleted() { } 

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