创建异步序列

public class Main { 
    public static void main(String[] args) throws InterruptedException { 
        Observable.interval(1, TimeUnit.SECONDS) .subscribe(System.out::println); 
        Thread.sleep(5000); 
    }
}