如何用RxJava实现无限循环？

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

public class InfiniteLoopExample {
    public static void main(String[] args) {
        Observable.create(emitter -> {
            int count = 0;
            while (!emitter.isDisposed()) {
                emitter.onNext(count);
                count++;
            }
            emitter.onComplete();
        }).subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 可以在此处进行资源的初始化操作
            }

            @Override
            public void onNext(Integer integer) {
                // 处理接收到的数据
                System.out.println("Received: " + integer);
            }

            @Override
            public void onError(Throwable e) {
                // 发生错误时的处理逻辑
            }

            @Override
            public void onComplete() {
                // 完成时的处理逻辑
            }
        });
    }
}