调用PublishSubject.onNext()和接收它之间的Rx间隔很长

PublishSubject<String> subject = PublishSubject.create();

// 发出事件的线程
new Thread(() -> {
    try {
        Thread.sleep(1000); // 模拟耗时操作
        subject.onNext("Hello");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

// 订阅并处理事件的线程
subject
    .observeOn(Schedulers.io()) // 切换到IO线程进行处理
    .subscribe(s -> System.out.println("Received: " + s));

PublishSubject<String> subject = PublishSubject.create();

// 先订阅
subject.subscribe(s -> System.out.println("Received: " + s));

// 后发出事件
subject.onNext("Hello");

subject
    .doOnError(throwable -> System.err.println("Error: " + throwable.getMessage()))
    .retry() // 重试机制
    .subscribe(s -> System.out.println("Received: " + s));

subject
    .doOnNext(s -> Log.d("PublishSubject", "Emitting: " + s))
    .doOnSubscribe(disposable -> Log.d("PublishSubject", "Subscribed"))
    .doOnDispose(() -> Log.d("PublishSubject", "Disposed"))
    .subscribe(
        s -> Log.d("PublishSubject", "Received: " + s),
        throwable -> Log.e("PublishSubject", "Error", throwable)
    );