仅发送事件而不一定是对象的主题 [RxJava]

在RxJava中，可以使用Subject来仅发送事件而不一定是对象的主题。下面是一个示例代码：

import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
import io.reactivex.subjects.PublishSubject;

public class Main {

    public static void main(String[] args) {
        // 创建一个PublishSubject
        PublishSubject<String> subject = PublishSubject.create();

        // 创建一个Observer
        Observer<String> observer = new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                // 当订阅时调用
            }

            @Override
            public void onNext(String value) {
                // 当接收到新的事件时调用
                System.out.println("Observer onNext: " + value);
            }

            @Override
            public void onError(Throwable e) {
                // 当发生错误时调用
            }

            @Override
            public void onComplete() {
                // 当事件序列结束时调用
            }
        };

        // 订阅Observer到Subject
        subject.subscribe(observer);

        // 发送事件到Subject
        subject.onNext("Event 1");
        subject.onNext("Event 2");
        subject.onNext("Event 3");

        // 输出结果：
        // Observer onNext: Event 1
        // Observer onNext: Event 2
        // Observer onNext: Event 3
    }
}

在上面的示例中，我们创建了一个PublishSubject，并创建了一个Observer来订阅这个Subject。然后，我们通过subject.onNext()方法发送事件到Subject，Observer会接收到这些事件并进行处理。