问如何使用retrofit和rxjava调用n次rest服务并在最后解释结果？

EN

private List<ResquestService> request;

private void process(){
    Observable.fromIterable(request)
    .filter(resquestService -> resquestService.getType().equals(WS_TYPE))
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeOn(Schedulers.newThread())
    .subscribe(
            resquestService -> {consumeRestService(resquestService);},
            Throwable::printStackTrace,
            () -> {processFinalResults();}
    );
}

private void consumeRestService(ResquestService resquestService){
    getApi().processData(resquestService)
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.newThread())
            .subscribe(
                    next -> {processResultWS();},
                    error -> {handleErrorWS();}
            );
}

public class ResquestService {
    private int id;
    private String name;
    private String type;
}