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...");