RX + Retrofit données du serveur filtring Réponse

Question

comment utiliser RxJava Fonction .filter() pour condition particulière, je veux juste seules les données id est de 168, ce est bonne façon de faire ou d'avoir à changer mon code le style donnez-moi votre suggestion valable. (Sans RetroLambda utilisation :))

NetworkRequest networkRequest = new NetworkRequest(this); 
RestApi api = networkRequest.getInstance().create(RestApi.class); 

    subscription = api 
      .school() 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Subscriber<Response<SchoolList>>() { 
       @Override 
       public void onCompleted() { 
        Log.d(TAG, "onCompleted: completed"); 
       } 

       @Override 
       public void onError(Throwable e) { 
        Log.d(TAG, "onError: on Error"); 
        e.printStackTrace(); 
       } 

       @Override 
       public void onNext(Response<SchoolList> schoolResponse) { 

        Log.d(TAG, "onNext: " + schoolResponse.getSchoolList().size()); 
       } 
      }); 

j'ai réponse comme

{ "schoolList": [ 
{ 
    "name": "A University", 

    "id": "168" 
}, 
{ 
    "name": "Alba Sciences", 
    "id": "271" 
}, 
{ 
    "name": "B University", 

    "id": "168" 
}] 
} 

j'ai essayer cette façon, mais faire remarquer dans (sur Suivant)

NetworkRequest networkRequest = new NetworkRequest(this); 
RestApi api = networkRequest.getInstance().create(RestApi.class); 

    subscription = api 
      .school() 
      .filter(new Func1<Response<SchoolList>, Boolean>() { 
       @Override 
       public Boolean call(Response<SchoolList> schoolListResponse) { 
        Log.d(TAG, "condition: computing 2"); 
        return schoolListResponse.getSchoolList().get(0).getId().equals("168"); 
       } 
      }) 
      .subscribeOn(Schedulers.computation()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Subscriber<Response<SchoolList>>() { 
       @Override 
       public void onCompleted() { 
        Log.d(TAG, "onCompleted: completed"); 
       } 

       @Override 
       public void onError(Throwable e) { 
        Log.d(TAG, "onError: on Error"); 
        e.printStackTrace(); 
       } 

       @Override 
       public void onNext(Response<SchoolList> schoolResponse) { 

        Log.d(TAG, "onNext: " + schoolResponse.getSchoolList().size()); 
       } 
      }); 

Answer 1

Je pense que vous devriez pouvoir t o utiliser quelque chose comme suit (recommandons fortement l'utilisation RetroLambda (ou Jack quand il est prêt) lors de l'utilisation RxJava)

api.school() 
      .flatMapIterable(schoolResponse -> schoolResponse.getSchoolList()) 
      .filter(school -> school.getId().equals("168")) 
      .toList() 

Answer 2

Voir avec FlatMap opérateur schoolItem votre élément sélectionné

api.school().flatMap(new Func1<SchoolListResponse, Observable<SchoolItem>>() { 
     @Override 
     public Observable<SchoolItem> call(SchoolListResponse schoolListResponse) { 
      return Observable.from(schoolListResponse.getSchoolList()); 
     } 
    }).filter(new Func1<SchoolItem, Boolean>() { 
     @Override 
     public Boolean call(SchoolItem schoolItem) { 
      return schoolItem.getId().equals("168"); 
     } 
    }).subscribe(new Subscriber<SchoolItem>() { 
     @Override 
     public void onCompleted() { 

     } 

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

     @Override 
     public void onNext(SchoolItem schoolItem) { 
      //schoolItem Filtered Item 
     } 
    });