Уточняющая резьба RxJava с прототипом

Question

В http://square.github.io/retrofit/, где говорится об асинхронной, есть фраза «Наблюдаемые запросы подписываются асинхронно и наблюдаются в том же потоке, который выполнял HTTP-запрос», где я хотел уточнить.

Итак, в этом случае поток, который фактически выполнит запрос Http: Позволяет сказать, что основной поток вызывает вызов Observable getUserPhoto (@Path («id») int id)? Будет ли основной поток или поток подписываться на запрос, выполняющий HTTP-запрос?

Answer 1

В отношении документации это будет поток, который выполняет запрос.

Если результат вашего запроса изменит что-то в представлении, вам может потребоваться наблюдать (потреблять) результат в основной теме. В этом случае добавьте вызов метода observOn, прежде чем подписываться на ваш наблюдаемый.

Answer 2

Ответ да, когда вы выполняете свой метод с помощью службы, метод randomOn создаст «Наблюдатель», который будет ждать возможности выполнить запрос, как только mainThread сможет это сделать.

Итак, сначала используйте .observeOn (AndroidSchedulers.mainThread()), чтобы наблюдать за основным потоком, а затем подписаться на действие или обратный вызов, который будет выполняться после получения ответа от удаленного API.

предположив использовать эту аннотацию в интерфейсе API

@GET("/home") 
Observable<Response> getHome(); 

это будет пример:

service.getHome().observeOn(AndroidSchedulers.mainThread()).subscribe(
       new Action1<Response>() { 
        @Override 
        public void call(Response response) { 
         System.out.println("Response home"); 
         System.out.println(response.getStatus()); 
         System.out.println(response.getBody().mimeType()); 
         System.out.println(response.getReason()); 
         System.out.println(response.getUrl()); 
         StringWriter w = new StringWriter(); 
         try{ 
          IOUtils.copy(response.getBody().in(),w,"UTF-8"); 
          System.out.println(w.toString()); 
         }catch (IOException e){} 

        } 
       }); 

Для получения дополнительной информации вы можете проверить это RxJava (тот, который модернизации использует конечно) link, где указано, что он использует обработчик Android (который является классом для обработки потоков).

«Он предоставляет планировщик, который планирует Наблюдаемый на данной потоке обработчика Android, в частности, основной пользовательский интерфейс . "