让订阅者订阅 RxJava 中的主题

Question

在 RxJava 3 中，有没有办法将 Subscriber 订阅到 Subject？ Subject 也是一个 Observable，这意味着它应该能够提供一个上游，当 Subject 的 onNext 发出某些东西时，其他人（Subscriber 实现，如 DisposableSubscriber 或 DefaultSubscriber）应该能够获取数据。但是下面的代码给出了编译时错误，我找不到任何其他机制来实现这一点。

public class NewsPublisher {
    static Subject<Integer>  newsSubject = PublishSubject.create();

public class NewsSubscriber
    extends DisposableSubscriber<Integer> {

    void bind() {
        NewsPublisher.newsSubject.subscribe(this);
    }

错误消息：无法解析方法“订阅（NewsSubscriber）”

Subject 的subscribe() 方法只允许Consumer 或Observer 作为输入。但从逻辑上讲，我想要的只是当 Subject（也是一个 Observable）发出一些东西时，我可以让一个 Subscriber 监听，因此它的 onNext() 被调用。

Answer 1

更新：

决定自己尝试代码并找到一种解决方法。使用 lambda 可以链接 onNext() 方法。 lambda istelf 是一个匿名 Consumer 对象，因此它可能会破坏整个类的目的（或不是？取决于你还在做什么），但这很有效。

import io.reactivex.rxjava3.disposables.Disposable;
import io.reactivex.rxjava3.subscribers.DisposableSubscriber;

public class NewsSubscriber extends DisposableSubscriber<Integer> {

    Disposable disposable;

    void bind() {
        disposable = NewsPublisher.newsSubject.subscribe(this::onNext);
    }

    public void onNext(Integer integer) {   
        // implement
    }

    public void onError(Throwable throwable) {
        if (disposable != null) disposable.dispose();
    }

    public void onComplete() {
        disposable.dispose();
    }
}