android - RxJava Thread.sleep 在另一个线程中

Question

如何在 Android 中使用 RxJava 每隔一秒更新一次 UI？我正在尝试做这样的事情:

 for (int i = 0; i <10 ; i++) { //test
               rx.Observable.just(getSleep())
                        .subscribeOn(Schedulers.newThread())
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribe(v->updateTime());//update textView
        }

    private <T> int getSleep() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return 0;
    }

但是 Thread.sleep() 在 ui 线程中执行。我做错了什么？

Answer 1

Observable.interval(1, TimeUnit.SECONDS) //emits item every second
            .observeOn(AndroidSchedulers.mainThread()) //switches thread from computation (interval's default) to UI
            .subscribe(i -> updateUI()); //update your textView