java - 创建主题

Question

我正在实现一个字节消息反序列化器，它将在调度程序接口(interface)上调度反序列化消息并返回所有 Throwable 的可观察值。抛出，以便客户端代码可以处理错误。

执行此操作的方法的原型(prototype)草图:

Observable<Throwable> dispatchDeserializedMessages(Observable<byte[]>, Dispatcher)

现在我最近熟悉Subject<T, R> ，这非常适合这里，例如

Subject<byte[], Throwable> dispatchDeserializedMessages(Dispatcher)

但是没有像 create() 这样的便捷方法它可以很容易地委托(delegate)给观察者和可观察的对象。所有具体实现统一T与 R ，所以我无法使用其中之一。

所以我的具体问题:有没有办法可以实例化一个合适的 Subject<byte[], Throwable>它委托(delegate)给 Observer和Observable ？有没有其他方法可以创建这样的 Subject无需实现(在必须手动委托(delegate)每个实现的方法的意义上)整个 Subject , Observable和Observer ？

Answer 1

切换到基于主题的 API 可能不是最好的主意，因为您将潜在的冷 API 更改为强制性的热 API。在您的原始设计中， Throwable 的消费者序列在订阅时会假设 Observable<byte[]>也被订阅。

否则，我有一个 blog series关于创建Subject但您无法避免与它们一起承担繁重的工作。