如何在x秒后开始观察

Question

让我们说10秒后开始观察的最佳方式是什么？

Single<Boolean> init(); 

public void onStart() { 
    init().subscribe(getMySubscriber()) 
} 

我想使`实际工作init启动以来认购10秒后。

Answer 1

使用delaySubscription延迟订阅到现有的源：

Single.just(1) 
    .delaySubscription(10, TimeUnit.SECONDS) 
    .subscribe(System.out::println); 

如果您init()方法本身有返回单个前副作用，你可以用Single.defer来包装它，上述结构仍然可以工作：

Single.defer(() -> init()) 
    .delaySubscription(10, TimeUnit.SECONDS) 
    .subscribe(System.out::println); 

Answer 2

Observable.timer()是你在找什么

Observable 
      .timer(10L, TimeUnit.SECONDS) 
      .subscribe(aLong -> init());