についてSchedulers.newThread（）

Question

public static void main(String[] args) { 
    List<Integer> list = Arrays.asList(1,2,3,4,5,6,7); 
    Observable.from(list) 
      .map(new Func1<Integer, String>() { 
       @Override 
       public String call(Integer integer) { 
        return String.format("%d ",integer); 
       } 
      }).subscribeOn(Schedulers.newThread()) 
      .observeOn(Schedulers.newThread()) 
      .subscribe(new Action1<String>() { 
       @Override 
       public void call(String s) { 
        System.out.print(s); 
       } 
      }); 
} 

これはrxjavaを使用するときのテストです。それは何も印刷しません。私は理由を知らない。だれでも私に助けを与えることができる？ありがとう。

Answer 1

RxJava標準スケジューラはデーモンスレッドです。 main()メソッドが終了すると、JVMは終了し、それらのデーモン・スレッドは停止します。

Thread.sleep(5000)をmain()メソッドの最後に配置すると、出力が表示されます。または.subscribe()コールの前に.toBlocking()を適用してください。