RxJava：如何向订阅者发送一些附加信息

Question

我创建了一个简单的方法，它将消息（作为对象）发送到给定的主题。在另一端，订阅者将使用该对象。

我将为多个消费者使用相同的主题，因此在发送消息时想要发送一些额外的信息，即 200、300。因此消费者可以过滤掉不相关的消息。但不知何故无法弄清楚如何做到这一点。

可以在postToSubject 方法和action1 处理附加信息（int 参数），但不确定如何将其放置在此处subject.onNext(object)

如果您能想到任何解决方案，请提出建议。

public void postToSubject(Object object, Subject subject) {
    Observable<Object> observable = Observable.create(new Observable.OnSubscribe<Object>() {
        @Override
        public void call(Subscriber<? super Object> subscriber) {
            subscriber.onNext(object);
            subscriber.onCompleted();
        }
    });
    observable.subscribe(new Action1() {
        @Override
        public void call(Object object) {
            subject.onNext(object);
        }
    });
}

上述方法调用如下（来自Android Activity，目标是将项目发送给主题。主题将由方法中的第二个参数返回）

在另一个 Android 组件类（继承自线性布局），该消息将被如下消费。如果我能获得更多信息，即 200, 300 ，我将过滤掉并将 onNext() 放入其中。这是我能想到的解决方案，但是 RxJava 专家可能会给出一个很好的解决方案。

答案：

通过 onNext() 传递的附加信息如下，订阅者将使用if (object instanceof Integer) 进行检查并放入逻辑以获取下一个 onNext() 返回的下一个值

Answer 1

首先，我不会使用Object 作为参数/消息类型，因为它太通用了。做一些基类，比如Item，携带基本信息。

其次，创建Item 的子类，例如MenuItem、ButtonItem、ParametrizedItem，等等。每个子类型都可以携带额外的信息。

第三，postToSubject() 应该是这样的：

public void postToSubject(Item object, Subject<Item> subject) {
    subject.onNext(object);
}

（不需要Observable.create...）

第四，在消费者端使用filter()运营商：

subject
    .filter(i -> i instanceof MenuItem)
    .subscribe(menuItemSubscriber);
subject
    .filter(i -> i instanceof ParametrizedItem)
    .subscribe(paramertizedItemSubscriber);

现在每个特定订阅者都知道它将接收哪些子类型项目，它可以安全地转换为该子类型，并提取与该子类型有关的其他信息。