rxJava 시간 초과 유틸리티를 사용할 때 TimeoutException이 발생하지 않습니다.

Question

5 초 내에 텍스트를 입력하지 않으면 TimeoutException이 발생하지 않습니다. 아래 코드 메서드는 getMsg()를 호출하고 텍스트 입력을 기다립니다. 나는 'timeout (5, TimeUnit.SECONDS)'을 추가하여 입력을 위해 5 초 동안 만 기다렸다. 사용자가 5 초 안에 msg를 입력하지 않은 경우 시간 초과 오류를 표시하려고합니다.

import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.util.concurrent.TimeUnit; 

import rx.Observable; 

public class TestRx { 

    public static void main(String[] args) throws IOException { 
     Observable.just(getMsg()) 
      .timeout(5, TimeUnit.SECONDS) 
      .subscribe(System.out::println, 
        e -> e.printStackTrace()); 
     System.out.println("End..."); 
    } 

    private static String getMsg() throws IOException { 
     BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); 
     System.out.print("Enter a msg:"); 
     String msg = reader.readLine(); 
     return msg; 
    } 
} 

Answer 1

getMsg()은 RxJava에 들어가기 전에 실행됩니다. just()은 괄호 안의 코드를 마술처럼 지연시키지 않습니다. 당신은 fromCallable 필요합니다 블로킹이 설정에서 중단되지 주 스레드에서 발생

public static void main(String[] args) { 
    Observable.fromCallable(() -> getMsg()) 
     .timeout(5, TimeUnit.SECONDS) 
     .subscribe(System.out::println, 
       e -> e.printStackTrace()); 
    System.out.println("End..."); 
} 

업데이트. 내가 그것을 가지고

Observable.fromCallable(() -> getMsg()) 
      .subscribeOn(Schedulers.io())    // <---------------------- 
      .timeout(5, TimeUnit.SECONDS) 
      .blockingSubscribe(System.out::println, 
        e -> e.printStackTrace()); 

System.out.println("End...");