JavaRx on ErrorReturn 返回不同的类型

Question

Observable 与类型相关联。当 onError 时，我不想返回相同类型但不同的对象。状态 = 400 的响应对象示例。如何实现这一目标？

public class Test{
    @Autowired
    private Server server;

    public Response getResponse(String id){
        Observable<Person>  personObservable = server.get(id);
        ExecutorService executorService = Executors.newFixedThreadPool(100);

        List<Person> persons = new ArrayList<Person>();
        personObservable.onErrorReturn(new Func1<Throwable, Person>() {
        @Override
         public Person call(Throwable throwable) {
              //I would like to return a HttpResponseObject taking the message
              //from throwable error information how to do it?
              // How to use Transform() in this case ?
              return null;
         }
        }).subscribeOn(Schedulers.from(executorService)).subscribe(new Action1<Person>() {
            // If i use subscribe() will it be not async?
            // I think subscribe still run on the main thread so is this
            // subscribeOn use fine ?
            @Override
            public void call(Person person) {
                // Is this fine to use the list outside the observable ?
                persons.add(person);
            }
       });
        Response r = new Response;
        r.addPersons(persons);
        return r;
    }
}

Answer 1

使用onErrorResumeNext:

Observable<Person> personObservable = ...;
return personObservable
             .toList()
             .map(persons -> new Response(persons))
             .onErrorResumeNext(error -> new Response(error.getMessage())
             .toBlocking().single();