RxJava Observable Threading with Retrofit

Question

http://square.github.io/retrofit/에서 비동기식으로 말하면 "관찰 가능한 요청은 비동기 적으로 구독되고 HTTP 요청을 실행 한 동일한 스레드에서 관찰됩니다"라는 구가 있습니다.

그래서이 경우 실제로 HTTP 요청을 실행할 스레드 : 주 스레드가 Observable getUserPhoto (@Path ("id") int id)를 호출한다고합시다. HTTP 요청을 실행하는 요청을 구독하는 주 스레드 또는 스레드일까요?

Answer 1

설명서와 관련하여 요청을 실행하는 스레드가됩니다.

요청 결과가보기에서 변경된 경우 주 스레드에서 결과를 관찰 (소비)해야 할 수도 있습니다. 이 경우 관찰 대상에 가입하기 전에 observeOn 메서드에 대한 호출을 추가하십시오.

Answer 2

대답은 예입니다. 서비스를 사용하여 메소드를 실행할 때 observeOn 메소드를 사용하면 mainThread가 기회가있을 때 요청을 실행할 수있는 기회를 기다리는 "관찰자"가 생성됩니다.

그래서 먼저 .observeOn (AndroidSchedulers.mainThread())을 사용하여 주 스레드를 관찰 한 다음 원격 API에서 응답을 얻으면 실행될 작업 또는 콜백을 구독하십시오.

이이 예가 될 것이다

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

당신의 API 인터페이스에서이 주석을 사용 랬 :이 RxJava (물론 사용을 개조 한)을 확인 할 수 있습니다 자세한 내용은

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){} 

        } 
       }); 

link 안드로이드의 Handler (쓰레드를 처리하는 클래스)를 사용한다고 명시되어있다.

"O 스케줄링 스케줄러를 제공한다. 주어진 안드로이드 처리기 스레드에서, 특히 메인 UI 스레드에서 bservable. "