java - 创建主题

Question

我在 RxJS 中看到过这个，但我还没有在 RxJava 中找到等效项。有谁知道如何在 Java 中设置这样的东西吗？

RxJS Subject.create(observer, observable)

Creates a subject from the specified observer and observable.

Arguments

observer (Observer): The observer used to send messages to the subject.

observable (Observable): The observable used to subscribe to messages sent from the subject.

基本上，这将是一个主题，您可以通过它向另一个观察者发送数据，并有一个可观察对象将数据发送回主题订阅者。

我正在尝试复制在 this github issue post 中看到的代码在 RxJava 中。

Answer 1

在 RxJava 中，我认为最接近的方法是订阅 Observable，将 Subject 作为观察者传递。

final Observable<Integer> observable = Observable.just(1, 2, 3, 4, 5);
final AsyncSubject<Integer> subject = AsyncSubject.create();
observable.subscribe(subject);
subject.subscribe(new Action1<Integer>() {
    @Override
    public void call(Integer integer) {
        // TODO
    }
});