RxJava 订阅 Flowable 的主题

Question

这似乎是一个显而易见的问题，但我似乎找不到答案。我想订阅一个Subject 到一个Flowable，但是这个方法似乎没有实现：

Flowable<Long> flowable = Flowable.just(1L, 2L, 3L);
Subject<Long> subject = PublishSubject.create();
subject.subscribe(System.out::println);
flowable.subscribe(subject); // Method cannot be resolved

然而对于 Observable 来说它是被实现的：

Observable<Long> observable = Observable.just(1L, 2L, 3L);
Subject<Long> subject = PublishSubject.create();
subject.subscribe(System.out::println);
observable.subscribe(subject); // Works

我错过了什么？是否有明显的原因说明为什么它没有实施？ Flowable 和 Subject 是否因某种原因不兼容？还是有其他方法可以达到我的目标？

Answer 1

Subject 是Observer，因此您可以订阅Observable，但不能订阅Flowable。

您可以使用PublishProcessor (Api docs)，而不是使用PublishSubject。