在RxJava中创建观察者以在每个时间间隔执行操作

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class RxJavaExample {
    public static void main(String[] args) {
        Observable<Long> observable = Observable.interval(1, TimeUnit.SECONDS);
        Observer<Long> observer = new Observer<Long>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 当观察者订阅时的回调方法
            }

            @Override
            public void onNext(Long value) {
                // 每次发出数值时的回调方法
                System.out.println("执行操作：" + value);
            }

            @Override
            public void onError(Throwable e) {
                // 发生错误时的回调方法
            }

            @Override
            public void onComplete() {
                // 完成事件流时的回调方法
            }
        };

        observable.subscribe(observer);
    }
}